From efb8f57bf240aa59798c09f5c99604a29969ca31 Mon Sep 17 00:00:00 2001 From: Helena McGough Date: Thu, 7 Dec 2017 08:18:33 +0000 Subject: [PATCH] Minor producer bug fix Change-Id: I09aa020a5e257fe68eb222f61862260d48f191e3 Signed-off-by: Helena McGough --- osm_mon/core/message_bus/producer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/osm_mon/core/message_bus/producer.py b/osm_mon/core/message_bus/producer.py index bccdd4c..85b608a 100755 --- a/osm_mon/core/message_bus/producer.py +++ b/osm_mon/core/message_bus/producer.py @@ -57,7 +57,7 @@ class KafkaProducer(object): self.producer = kaf( key_serializer=str.encode, - value_serializer=lambda v: json.dumps(v).str.encode, + value_serializer=str.encode, bootstrap_servers=broker, api_version=(0, 10)) def publish(self, key, value, topic=None): -- 2.25.1