X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=core%2Fmessage_bus%2Fproducer.py;fp=core%2Fmessage_bus%2Fproducer.py;h=1b0de7ae34f305c95c17b4ddded42a91ac369399;hb=892944acd3cd91613e173cf0efc4507775793e44;hp=f5abce218d1df3dfcfc84192a396ef6e8808c240;hpb=6a76e7045a98043170ac6517b3bf57481d5275e5;p=osm%2FMON.git

diff --git a/core/message_bus/producer.py b/core/message_bus/producer.py
index f5abce2..1b0de7a 100644
--- a/core/message_bus/producer.py
+++ b/core/message_bus/producer.py
@@ -65,7 +65,7 @@ class KafkaProducer(object):
 
     def publish(self, key, value, topic=None):
         try:
-            future = self.producer.send(key, value, topic)
+            future = self.producer.send(topic=topic, key=key, value=value)
             self.producer.flush()
         except Exception:
             logging.exception("Error publishing to {} topic." .format(topic))