从文件运行代码和从sh运行代码时的不同行为

Question

我正在学习如何在python下使用卡夫卡

我让kafka服务器运行，一个消费者正在mytopic上监听

现在我使用confluent-kafka编写了这段代码：

from confluent_kafka import Producer
p = Producer({'bootstrap.servers': 'localhost:9092'})
p.produce('mytopic', key='hello', value='world')

当我运行python并粘贴代码时，它可以工作（消费者正在收集）

但是，如果将其保存到example.py并运行python example.py，则不会

有人明白吗

Answer 1

从文件运行代码时，它会在最后一行之后立即终止

要等待生产者在关闭前发送所有消息，您需要调用flush()：

p.flush()

参见API文档：https://docs.confluent.io/current/clients/confluent-kafka-python/index.html#confluent_kafka.Producer.flush