kafka本地发消息问题

问题一、1.在kafka manager点击topic时会报如下的错误

2.问题原因:在kafka manager创建Clusters时,配置Cluster Zookeeper Hosts为本机ip地址,我的电脑ip地址不是固定的,当本机ip变更与配置Cluster Zookeeper Hosts的ip地址不同时会出现上图中的问题。

3.解决方法:到系统偏好设置中将IPv4地址固定,将Cluster Zookeeper Hosts配置为固定后的本机ip地址。

问题二、1.发送消息

2.报错如下:找不到broker

3.问题原因:

经检查在kafka manager中发现我的broker主机地址与我本机的ip地址不一致,原因是由于我之前本机ip不是固定的,之前配置的broker主机地址使用的localhost是之前的ip地址,导致broker host的地址与zookeepers的地址不一致,所以产生了找不到broker的问题

4.解决方法:

将localhost改成PLAINTEXT配置的IP地址即可,估计localhost这个地址没配置到PLAINTEXT当中,kafka不认。尽量不要使用localhost,直接使用本机ip。

到/usr/local/etc/kafka/server.properties中修改配置文件,修改后重启kafka和zookeeper服务,重启电脑后神奇的解决了。。


更多的broker配置可参考http://www.cnblogs.com/rilley/p/5391268.html

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容