/storm-ten-framework

basic framework for reading and writing from kafka and hbase

Primary LanguageJava

basic framework for reading and writing from kafka and hbase

##KAFKA## To run:

mvn clean compile exec:java -Dexec.mainClass="com.frameworks.storm.topology.KafkaConsumeTopology" -Dexec.args="storm-one-framework-1.0.0-SNAPSHOT-storm.jar"
need to change last line of topology code to: cluster.submitTopology(...);

or alternatively:

storm jar target/storm-one-framework-1.0.0-SNAPSHOT-storm.jar com.frameworks.storm.topology.KafkaConsumeTopology
need to change last line of topology code to: StormSubmitter.submitTopology("kafkaTridentTest", conf, topology.build());

##HBASE##

mvn clean compile exec:java -Dexec.mainClass="com.frameworks.storm.topology.HBaseWriterTopology" -Dexec.args="storm-one-framework-1.0.0-SNAPSHOT-storm.jar"