From 892944acd3cd91613e173cf0efc4507775793e44 Mon Sep 17 00:00:00 2001 From: Helena McGough Date: Mon, 2 Oct 2017 17:02:01 +0100 Subject: [PATCH] Small bug fix in producer.py Signed-off-by: Helena McGough --- core/message_bus/producer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)) -- 2.25.1