消费者在运行生产者和消费者 python 脚本时不显示任何消息

Question

我在Ubuntu服务器上设置了Apache Kafka，并按照https://kafka.apache.org/quickstart中提到的前五个步骤进行了测试，一切正常。

然后，我继续安装kafka python 1.4.6以在python中进行测试，并编写了简单的生产者和消费者脚本。

我的侦听器
侦听器配置=纯文本：//本地主机：9092
播发.侦听器=纯文本：//本地主机：9092

这是脚本

consum.py

from kafka import KafkaConsumer

consumer = KafkaConsumer('my-topic')
for message in consumer:
        print (message)

产品.py

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers='localhost:9092',api_version=(0, 10, 1))

producer.send('my-topic', b'Hello')

运行脚本时，生产者脚本立即完成，消费者脚本不会打印任何消息

你知道我可能错过了什么吗？谢谢

Answer 1

问题是您的创建者脚本在发送消息之前完成。运行 send（） 后，Python 到达脚本的最后一行并立即停止运行。

您需要调用flush（）来强制运行库在终止之前等待所有消息发送。

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers='localhost:9092',api_version=(0, 10, 1))

producer.send('my-topic', b'Hello')

producer.flush()

除此之外，你的逻辑看起来很好（对我来说很有效）。