Commit cf086404 authored by 张彦钊's avatar 张彦钊

change test file

parent aded7896
......@@ -18,7 +18,7 @@ def on_send_error():
if __name__ == "__main__":
producer = KafkaProducer(bootstrap_servers=['172.16.44.25:9092'],key_serializer=lambda k: pickle.dumps(k),value_serializer=lambda v: pickle.dumps(v))
producer = KafkaProducer(bootstrap_servers=['173.16.44.25: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")
try:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment