change

4c57c8ab · 张彦钊 · c97bd222 · 4c57c8ab
Commit 4c57c8ab authored Aug 08, 2019 by 张彦钊
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

ctr.py ctr.py +1 -1

No files found.
--- a/ctr.py
+++ b/ctr.py
@@ -165,7 +165,7 @@ 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"],
+    producer = KafkaProducer(bootstrap_servers=["172.16.44.25:9092","172.16.44.31:9092","172.16.44.45:9092"],
                             key_serializer=lambda k: pickle.dumps(k), value_serializer=lambda v: pickle.dumps(v))
    print("hajs")
    future = producer.send(topic="test_topic", key="hello", value="world")