python连接kafka集群保证broker不可用时正常发送,kafkabroker,producer的代码:
python连接kafka集群保证broker不可用时正常发送,kafkabroker,producer的代码:
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?
如何保证这种情况下也能正常工作?
你的报错说的是你的host确定配对了?DNS显然找不到你的ip,这和你的kafka集群的高可用并没有什么关系
编橙之家文章,
相关内容
- python删除字符串str中指定位置字符,pythonstr,原程序是这
- python scrapy抓取时302重定向的问题,pythonscrapy,我用scra
- scrapy框架采集时如何快速避开重复数据?,scrapy框架采集
- Ubuntu版本16:The following packages have unmet dependencies?,ub
- pyqt GUI类,继承自QTableWidget鼠标滚轮失效,pyqtqtablewid
- pyspider分布式控制某一工程的工作节点数量?,pyspide
- pyqt,tablewidget,单元格内容变化单元格背景颜色变化一
- python 调用selenium加载时间过长,pythonselenium,本人py新手
- 怎样防止对Python字符串变量转义,python字符串转义,例如
- keep-alive的http会话中用新的cookie、user-agent发起请求的结
评论关闭