kafa使用時報錯:kafka.errors.NoBrokers Available 的主要可能原因是:
1. 沒有依次啟動 zookeeper 和 kafka;
2. kafka配置文件中 host沒有寫對:例如有些是 localhost:9092(local版)
此時馬上檢查這兩部分即可。
打開zookeeper報錯:WARN [NIOWorkerThread-5:NIOServerCnxn@373] - Close of session 0x100457e83740000 java.io.IOException: 遠程主機強迫關閉了一個現有的連接。
解決:
需要刪除zookeeper的log文件:例如windows的C:\Users\Administrator\zookeeper-x.x.x\data\version-2\
刪除:zookeeper-x.x.x/data/version-2/ 下面的數據(即conf/zoo.cfg配置文件定義的dataDir=/home/zookeeper-x.x.x/data和dataLogDir=/home/zookeeper-x.x.x/logs 下的數據)
開啟kafka報錯:The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.
解決:
在Kafka的config目錄中,打開kafka config屬性文件,讓server.properties查找具有參數log.dirs =的日志路徑目錄(log文件),然后轉到日志路徑目錄並在其中找到文件meta.properties。打開文件meta.properties並更新cluster.id =【這個值是error里面有寫的】或從日志路徑目錄中刪除此文件或所有日志文件(本人使用),然后重新啟動kafka。
【注意:刪除log文件夾會直接刪除topics】
#
參考:
https://blog.csdn.net/reblue520/article/details/80553506
https://www.manongdao.com/article-2281758.html