問題一、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