From: Helena McGough 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=refs%2Fchanges%2F90%2F5490%2F1;p=osm%2FMON.git Small bug fix in producer.py Signed-off-by: Helena McGough --- 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))