美文网首页
kafka本地发消息问题

kafka本地发消息问题

作者: 张鑫zhangxin | 来源:发表于2019-03-06 17:30 被阅读0次

    问题一、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

    相关文章

      网友评论

          本文标题:kafka本地发消息问题

          本文链接:https://www.haomeiwen.com/subject/afhzyqtx.html