Skip to content

Latest commit

 

History

History
executable file
·
23 lines (18 loc) · 552 Bytes

README.md

File metadata and controls

executable file
·
23 lines (18 loc) · 552 Bytes

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