MON vROPs plugin updates -

[osm/MON.git] / core / message_bus / producer.py

diff --git a/core/message_bus/producer.py b/core/message_bus/producer.py
index 4956292..f5abce2 100644 (file)
--- a/core/message_bus/producer.py
+++ b/core/message_bus/producer.py
@@ -47,13 +47,13 @@ class KafkaProducer(object):
 
         self._topic= topic
 
 
         self._topic= topic
 

-        if "ZOOKEEPER_URI" in os.environ:
-            broker = os.getenv("ZOOKEEPER_URI")
+        if "BROKER_URI" in os.environ:
+            broker = os.getenv("BROKER_URI")

         else:
         else:

-            broker = "localhost:2181"
+            broker = "localhost:9092"

 
         '''
 
         '''

-        If the zookeeper broker URI is not set in the env, by default,
+        If the broker URI is not set in the env, by default,

         localhost container is taken as the host because an instance of
         is already running.
         '''
         localhost container is taken as the host because an instance of
         is already running.
         '''