Kafka Python Client - Как обрабатывать возможные ошибки соединения / тайм-аута?

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-сервер и потребителя и попробуйте снова.

Пожалуйста, найдите мой ответ в другой ветке, такая же проблема, как и у вас. NoBrokersAvailable: ошибка NoBrokersAvailable-Kafka