python-3.x - Kafka Python 客户端 - 如何处理可能的连接/超时错误？

Question

我正在编写一个 Python 应用程序，它连接到 Kafka 队列并向队列发送消息。我有以下工作代码：

def send_msg(self, topic, msg):
    self.producer = KafkaProducer(bootstrap_servers=['XX.XXX.XX.XXX:XXXX'])
    future = self.producer.send(topic, msg)
    self.producer.flush()

我想在这段代码中添加标准的 try-catch 表达式，这样我就可以捕获我可能遇到的任何类型的异常。连接、超时、NoBrokersAvailable 等各种异常是什么？我应该如何正确处理它们？

提前致谢！

Answer 1

设置advertised.listeners=PLAINTEXT://<broker_ip>:9092在server.properties. 重新启动您的 kafka-server 和使用者，然后重试。

请在另一个线程中找到我的答案，与您的问题相同。 NoBrokersAvailable：NoBrokersAvailable-Kafka 错误