Kafka Python Client - 可能な接続/タイムアウトエラーを処理する方法は？

Question

私はKafkaのキューに接続し、キューにメッセージを送信するPythonアプリケーションを書いています。私は私が直面するかもしれない例外のいずれかの種類をキャッチできるように、このコードでは、標準のtry-catch式を追加したい

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() 

：私は、次の作業のコードを持っています。接続、タイムアウト、NoBrokersAvailableなどのさまざまな例外は何ですか、どうすれば適切に処理する必要がありますか？

ありがとうございます！

Answer 1

advertised.listeners=PLAINTEXT://<broker_ip>:9092をserver.propertiesに設定します。カフカサーバーとコンシューマーを再起動して、もう一度お試しください。

別のスレッドで私の答えを見つけてください、あなたと同じ問題です。 NoBrokersAvailable: NoBrokersAvailable-Kafka Error