/storm-kafka-example

storm-kafka-example

Primary LanguageJavaApache License 2.0Apache-2.0

strom-kafka-examples

Process Design

storm-kafka-hdfs

Testing

  1. Linux Terminal execute command
    zookeeper-cli   # create /order /id
  1. Maven package to target directory
  • send msg to kafka
    storm jar storm-kafka-examples-1.0-SNAPSHOT.jar cn.inspur.sendmsg.SendMessageKafka
  • storm processing data
    storm jar storm-kafka-examples-1.0-SNAPSHOT.jar cn.inspur.kafka_storm.topology.CounterTopology
  • Processing data to HDFS,Running results hadoop fs -ls /tmp/order_hdfs-xxx.log