kafka+storm 联调完成

leoowu · Apr 3, 2015 · 2eb2185 · 2eb2185
1 parent b2aef5b
commit 2eb2185
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/common/mystorm/README.md b/common/mystorm/README.md
@@ -54,13 +54,14 @@ Storm的主要特点如下：
 >   1.2 按mytools/common/mykafka/的数据采集-运行示例1的步骤启动；
 >   1.3 先创建topic：
 >       kafka-topics.sh --create --zookeeper 192.168.59.103:2181 --replication-factor 1 --partitions 1 --topic storm-sentence
->   1.3 生产数据：telnet 192.168.59.103 44447
+>   1.3 生产数据：telnet 192.168.59.103 44450
 >
 > 2.启动Topology作为Kafka的comsumer( -c nimbus.thrift.port=49627)
 >   2.1 git clone https://github.com/supermy/storm-kafka-0.8-plus-test.git/
 >   2.2 mvn package
->   2.3 java -cp target/storm-kafka-0.8-plus-test-0.2.0-SNAPSHOT-jar-with-dependencies.jar storm.kafka.trident.SentenceAggregaonTopology 192.168.59.103:2181
->
+>   2.3 运行示例
+>   java -cp storm-kafka-0.8-plus-test-0.2.0-SNAPSHOT-jar-with-dependencies.jar storm.kafka.KafkaSpoutTestTopology 192.168.59.103:2181
+>   java -cp target/storm-kafka-0.8-plus-test-0.2.0-SNAPSHOT-jar-with-dependencies.jar storm.kafka.trident.SentenceAggregationTopology 192.168.59.103:2181
 > 3.观察Storm数据处理情况
 >
 > ## 日志输出到屏幕
diff --git a/common/mystorm/start.sh b/common/mystorm/start.sh
@@ -1,3 +1,3 @@
 fig up -d && fig ps
 kafka-topics.sh --create --zookeeper 192.168.59.103:2181 --replication-factor 1 --partitions 1 --topic storm-sentence
-fig logs flume1
+java -cp storm-kafka-0.8-plus-test-0.2.0-SNAPSHOT-jar-with-dependencies.jar storm.kafka.KafkaSpoutTestTopology 192.168.59.103:2181
diff --git a/common/mystorm/storm-kafka-0.8-plus-test-0.2.0-SNAPSHOT-jar-with-dependencies.jar b/common/mystorm/storm-kafka-0.8-plus-test-0.2.0-SNAPSHOT-jar-with-dependencies.jar
diff --git a/common/mystorm/storm-starter-topologies-0.9.4.jar b/common/mystorm/storm-starter-topologies-0.9.4.jar