在这里插入图片描述
python-kafka KafkaTimeoutError连接不上kafka

问题分析:

当代码解析时,会把kafka的地址解析成在zookeeper中设置的kafka名称。所以,需要配置对应名称到相应ip的etc/hosts映射。

解决办法:

vim /etc/hosts 加入别名和ip 映射

20.0.28.14 kafka1
20.0.28.15 kafka2
20.0.28.16 kafka3

wq! 保持即可。

然后使用kafka1 别名 作为kafka host

kfk_host="kafka1:9092"
Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐