kafka消費(fèi)異常

現(xiàn)象
kafka能正常寫入數(shù)據(jù)，但是無法消費(fèi)到數(shù)據(jù)，無論是console還是代碼都不行，不論是zk消費(fèi)方式還是bootstrap-server方式都不行

處理思路
1.kafka能生產(chǎn)數(shù)據(jù)，那么說明網(wǎng)絡(luò)是正常無異常
2.無法消費(fèi)數(shù)據(jù)，那么說明是kafka自身可能存在問題

處理方法簡介
1.查看所有主題分片信息是否正常

kafka-topics.sh  --zookeeper localhost:2181 --describe  --topic  topicName
#--topic參數(shù)指定某一個(gè)主題，不加就默認(rèn)羅列所有主題信息
#此處羅列出來的分片信息可以看到leader在哪一個(gè)node上，如果出現(xiàn)leader:-1則就是對應(yīng)的topic不能實(shí)現(xiàn)均衡負(fù)載了

2.查看meta信息是否正常

recovery-point-offset-checkpoint
replication-offset-checkpoint
到kafka的后臺(tái)，查看以上兩個(gè)配置文件是否可閱讀，非亂碼，如果是亂碼，則會(huì)影響到所有topic無法消費(fèi)
上面第一種情況中，出現(xiàn)leader找不到問題，只會(huì)影響到單個(gè)topic的讀問題
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

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

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