Kafka-python脚本无法正确执行

Question

我在Python Shell中运行了以下代码：

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')
future = producer.send('hello-topic', b'Hello, World!')

这在Kafka消费者接收消息方面工作得很完美。

但是..。

通过脚本运行它不会产生任何影响。我是不是漏掉了什么明显的东西？

让它作为脚本工作的唯一方法是添加下面这一行...

future.get(timeout=10)

任何帮助都将不胜感激。

Answer 1

来自link：send()的kafka send()细节是异步的。当被调用时，它会将记录添加到挂起记录发送的缓冲区中，并立即返回。这使得生产者可以批量处理单个记录，以提高效率。您可以使用flush()/poll()方法立即发送消息。