X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=core%2Fmessage_bus%2Fproducer.py;h=f5abce218d1df3dfcfc84192a396ef6e8808c240;hb=e6d1dbb5403c4d98c0d5ca12731b4465bb7cf022;hp=49562921231e0c64e428bba2223b0f47e2868607;hpb=e834a774df8b09fa1705f55b152973cfef9ecd26;p=osm%2FMON.git

diff --git a/core/message_bus/producer.py b/core/message_bus/producer.py
index 4956292..f5abce2 100644
--- a/core/message_bus/producer.py
+++ b/core/message_bus/producer.py
@@ -47,13 +47,13 @@ class KafkaProducer(object):
 
         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:
-            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.
         '''