问题一、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
网友评论