change

ctr.py

@@ -166,7 +166,8 @@ def Filter_Data(data):
 
 def write_to_kafka():
     producer = KafkaProducer(bootstrap_servers=["172.16.44.25:9092","172.16.44.31:9092","172.16.44.45:9092"],
-                             key_serializer=lambda k: json.dumps(k), value_serializer=lambda v: json.dumps(v))
+                             key_serializer=lambda k: json.dumps(k).encode('utf-8'),
+                             value_serializer=lambda v: json.dumps(v).encode('utf-8'))
     future = producer.send(topic="test_topic", key="hello", value="world")
     try:
         record_metadata = future.get(timeout=10)