kafka本地發(fā)消息問題

問題一、1.在kafka manager點擊topic時會報如下的錯誤

2.問題原因:在kafka manager創(chuàng)建Clusters時,配置Cluster Zookeeper Hosts為本機(jī)ip地址,我的電腦ip地址不是固定的,當(dāng)本機(jī)ip變更與配置Cluster Zookeeper Hosts的ip地址不同時會出現(xiàn)上圖中的問題。

3.解決方法:到系統(tǒng)偏好設(shè)置中將IPv4地址固定,將Cluster Zookeeper Hosts配置為固定后的本機(jī)ip地址。

問題二、1.發(fā)送消息

2.報錯如下:找不到broker

3.問題原因:

經(jīng)檢查在kafka manager中發(fā)現(xiàn)我的broker主機(jī)地址與我本機(jī)的ip地址不一致,原因是由于我之前本機(jī)ip不是固定的,之前配置的broker主機(jī)地址使用的localhost是之前的ip地址,導(dǎo)致broker host的地址與zookeepers的地址不一致,所以產(chǎn)生了找不到broker的問題

4.解決方法:

將localhost改成PLAINTEXT配置的IP地址即可,估計localhost這個地址沒配置到PLAINTEXT當(dāng)中,kafka不認(rèn)。盡量不要使用localhost,直接使用本機(jī)ip。

到/usr/local/etc/kafka/server.properties中修改配置文件,修改后重啟kafka和zookeeper服務(wù),重啟電腦后神奇的解決了。。


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

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容