Getting End 2 End running - scottlove/MessageProducer GitHub Wiki

Zookeepers

  • Start Zookeeper,Zookeeper2, Zookeeper 3
  • Check logs of each to make sure they are running
  • use:echo stat | nc 127.0.0.1 2181 to verify functionality
  • echo ruok | nc 127.0.0.1 2181 (returns if it is okay, look carefully at next line for imok)

#Kafka

  • Start kafkaserver, kafkaserver2
  • Use to verify working: sudo ./kafka-list-topic.sh --zookeeper zookeeper:2181

#Storm Cluster

  • Start Nimbus
  • StormWorker1, StormWorker2
  • Start word count job

cd into storm directory

bin/storm jar ~/Storm-1.0-SNAPSHOT-jar-with-dependencies.jar stormapp.Topology.TopologyKafka word-count

ApacheHost1 8082

#MessageServerApp *Start Netty1 server

#Start up producer, consumer and MessageAgg

  • Verify MessageMonitor,MessageSenderSample,ConsumerSample, and MessageAgg processes are running
  • verify everything is working by going to: http://kafkaserver.cloudapp.net/test.html
  • check ~/app/MessageMonitor/trace.html is getting data
  • check ~/app/MessageAgg/logs to ensure we are receiving data

#Apache web server web root is at /var/www/testApp