使用python连接kafka集群做producer,如何保证部分broker不可用时仍然正常发送?
巴扎黑
巴扎黑 2017-04-18 10:16:21
0
1
418

producer的代码:

kafka_addr = "n0.xxx.com:9092,n1.xxx.com:9092,n2.xxx.com:9092"
producer = KafkaProducer(bootstrap_servers=kafka_addr)

问题:
当部分broker挂掉或者网络不通(比如n2)而至少有一个broker可用时,producer报错:

getaddrinfo failed for n2.xxx.com:9092, exception was [Errno 8] nodename nor servname provided, or not known. Is your advertised.host.name correct and resolvable?

如何保证这种情况下也能正常工作?

巴扎黑
巴扎黑

人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート
私たちについて 免責事項 Sitemap
PHP中国語ウェブサイト:福祉オンライン PHP トレーニング,PHP 学習者の迅速な成長を支援します!