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

Question

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

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服务器和客户端，然后重试。

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