Python KafkaProducer继续执行操作，因为无法在超时时间内完成挂起的请求，因此强制关闭生产器

Question

在此报告问题。生产者将以下错误抛出。等了一个小时左右，错误消失了。但是当我遇到错误时，我可以使用Kafka工具列出主题，而Kafka Python API无法使用：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic tweets

这里是python程序的错误：

INFO：kafka.producer.kafka：自从开始强制关闭生产者以来，暂挂请求无法在超时0内完成。

使用中

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')

Answer 1

您的生产者内核很可能在发送消息后立即关闭；甚至在消费者能够使用和显示消息之前。您可以尝试在生产者脚本广告尝试中添加睡眠（秒）吗？为我工作！