kafka-producer-api - Python KafkaProducer 由于无法在超时内完成挂起的请求而继续强制关闭生产者

Question

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

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

这是来自python程序的错误:

INFO:kafka.producer.kafka:Proceeding to force close the producer since pending requests could not be completed within timeout 0.

使用

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

Answer 1

您的生产者内核很可能在发送消息后立即关闭；甚至在消费者能够消费和显示消息之前。您可以尝试将 sleep(seconds) 添加到您的制作人脚本广告中吗？为我工作!