From: Helena McGough <helena.mcgough@intel.com>
Date: Mon, 2 Oct 2017 16:02:01 +0000 (+0100)
Subject: Small bug fix in producer.py
X-Git-Tag: v4.0.0~68
X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;h=892944acd3cd91613e173cf0efc4507775793e44;p=osm%2FMON.git

Small bug fix in producer.py

Signed-off-by: Helena McGough <helena.mcgough@intel.com>
---

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))