Kafka Python 客户端 - 如何处理可能的连接/超时错误？答案

【问题标题】：Kafka Python Client - How to handle possible connection/timeout errors?Kafka Python 客户端 - 如何处理可能的连接/超时错误？
【发布时间】：2017-07-10 17:20:42
【问题描述】：

我正在编写一个 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 等各种异常是什么，我应该如何正确处理它们？

提前致谢！

【问题讨论】：

标签： python-3.x kafka-producer-api kafka-python

【解决方案1】：

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

请在另一个帖子中找到我的答案，与您的问题相同。 NoBrokersAvailable: NoBrokersAvailable-Kafka Error

【讨论】：