Kafka启动失败异常-InconsistentClusterIdException
一、場景
通過Kafka啟動命令啟動Kafka無響應,每臺機器的Zookeeper都已啟動,但是Kafka無響應。或者出現
命令剛啟動的時候jps可見kafka進程,但是過一點時間后又消失不見。
總是會報出Exit錯誤。
經過排查Kafka啟動日志,發現異常錯誤信息。
二、異常錯誤信息
通過查看 Kafka啟動日志(server.log),得到錯誤異常信息(kafka.common.InconsistentClusterIdException: The Cluster ID JinmlOdtR2a9MmYaeAS78g doesn't match stored clusterId Some(903zjls1SQafSy5N-o5-4Q) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.)。
三、原因分析及解決方案
Kafka啟動異常的原因是,Kafka的數據日志(logs)文件中 記錄的cluster.id與配置文件meta.properties
中的cluster.id不匹配造成的。
解決方案:
? 刪除日志目錄(缺點是會造成日志數據全部丟失…)
? 刪除data目錄下的meta.properties文件
? 重啟Kafka
----------------------------------更新----------------------------------
補充
異常錯誤
經過排查發現,是因為自己關閉Kafka時,使用命令不當,導致Kafka異常關閉,日志記錄該異常,導致后續啟動Kafka時記錄的cluster.id與配置文件meta.properties中的cluster.id不匹配。
錯誤關閉指令:nohup bin/kafka-server-stop.sh config/server.properties 2>&1 &
解決方案
先用上述辦法解決該問題,之后再關閉Kafka時輸入正常關閉指令即可。
正確關閉指令:/export/server/kafka_2.12-2.4.1/bin/kafka-server-stop.sh
/export/server/kafka_2.12-2.4.1/bin/
為Kafka所在路徑
總結
以上是生活随笔為你收集整理的Kafka启动失败异常-InconsistentClusterIdException的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 【openjudge 计算概论(A)】[
- 下一篇: 基于Java的建筑工程综合管理信息系统