commit ea2922cabe441abcf0475445d94cffed0d0fa131
author khen <knursimu@ciena.com> Wed Oct 05 11:17:31 2016 -0700
committer khen <knursimu@ciena.com> Wed Oct 05 11:17:31 2016 -0700
tree ae79fb868f4b1088b59bf7581aa656123c833295
parent b95fe9a29fcd7d38a410bf52d998dd5de566957d

Update IP address of kafka consumer

kafka/kafkaConsumer.py

diff --git a/kafka/kafkaConsumer.py b/kafka/kafkaConsumer.py
index 2fd61e8..f6ae9ad 100644
--- a/kafka/kafkaConsumer.py
+++ b/kafka/kafkaConsumer.py
@@ -8,8 +8,8 @@
     daemon = True
 
     def run(self):
-        #consumer = KafkaConsumer(bootstrap_servers='10.100.198.220:9092',
-        consumer = KafkaConsumer(bootstrap_servers='10.0.2.15:9092',
+        consumer = KafkaConsumer(bootstrap_servers='10.100.198.220:9092',
+        #consumer = KafkaConsumer(bootstrap_servers='10.0.2.15:9092',
                                  auto_offset_reset='earliest')
         consumer.subscribe(['voltha-heartbeat'])