kafka報錯:kafka.errors.NoBrokers Available,Close of session 0x100457e83740000 java.io.IOException 和 The broker is trying to join the wrong cluster


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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM