kafka啟動(dòng)報(bào)錯(cuò)(Cluster ID)不匹配問題以及解決
kafka啟動(dòng)報(bào)錯(cuò)(Cluster ID)不匹配問題
有時(shí)候在啟動(dòng)Kafka的時(shí)候會(huì)出現(xiàn)如下報(bào)錯(cuò)信息：
InconsistentClusterIdException: The Cluster ID -A0n-rHCT9e5IadkrA0tkw doesn't match stored clusterId Some(E-xpRlfuRqicvCYyRf9O9w) in meta.properties.
The broker is trying to join the wrong cluster.
Configured zookeeper.connect may be wrong.
個(gè)人嘗試的解決方法
是找到上面提到的meta.properties文件，這個(gè)文件在kafka的bin目錄下的installkafka_2.13-2.5.0logs目錄下
（如果是Windows系統(tǒng)，則在bin/windows目錄）
這個(gè)目錄是在Kafka初次成功啟動(dòng)后就自動(dòng)生成的，后續(xù)創(chuàng)建主題和索引偏移量等信息都會(huì)在這個(gè)目錄
目錄文件如下
installkafka_2.13-2.5.0logs目錄
將該文件中的cluster.id的值改成和報(bào)錯(cuò)信息中的值一樣即可，不需要其他操作：
但還是要注意該操作會(huì)不會(huì)對(duì)之前生產(chǎn)的數(shù)據(jù)造成影響（雖然我自己測(cè)試的結(jié)果是沒有影響，之前消費(fèi)過的數(shù)據(jù)仍然能夠消費(fèi)）。
下面附上Kafka的一些操作命令
- 啟動(dòng)zookeeper：
.\zookeeper-server-start.bat ..\..\config\zookeeper.properties
- 啟動(dòng)Kafka：
.\kafka-server-start.bat ..\..\config\server.properties
- 創(chuàng)建主題：
.\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 主題名稱1
- 查看主題：
.\kafka-topics.bat --zookeeper localhost:2181 --list
- 生產(chǎn)者生產(chǎn)消息：
.\kafka-console-producer.bat --broker-list localhost:9092 --topic 主題名稱1
- 消費(fèi)者消費(fèi)消息：
.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic 主題名稱1 --from-beginning
總結(jié)
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
解決mapstruct在eclipse生成不了mapper的實(shí)現(xiàn)類問題
這篇文章主要介紹了解決mapstruct在eclipse生成不了mapper的實(shí)現(xiàn)類問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11
本文小編給大家整理了在Java中關(guān)于靜態(tài)調(diào)用和動(dòng)態(tài)調(diào)用的方法匯總，值得大家學(xué)習(xí)和參考。2017-11-11
大量閑置 MySQL 連接會(huì)直接導(dǎo)致 MySQL 連接數(shù)耗盡（Too many connections）、服務(wù)器資源（內(nèi)存/文件句柄）浪費(fèi)、數(shù)據(jù)庫響應(yīng)變慢等問題,所以本文給大家介紹了Java中大量閑置MySQL連接的解決方案,需要的朋友可以參考下2025-12-12
序列化版本號(hào)serialVersionUID的作用_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
Java序列化是將一個(gè)對(duì)象編碼成一個(gè)字節(jié)流，反序列化將字節(jié)流編碼轉(zhuǎn)換成一個(gè)對(duì)象,這篇文章主要介紹了序列化版本號(hào)serialVersionUID的作用，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-05-05
JVM在運(yùn)行的時(shí)候會(huì)對(duì)class文件進(jìn)行加載，鏈接和初始化的過程。class文件中定義的常量池在JVM加載之后會(huì)發(fā)生什么神奇的變化呢？快來看一看吧。2021-06-06
Java使用備忘錄模式實(shí)現(xiàn)過關(guān)類游戲功能詳解
這篇文章主要介紹了Java使用備忘錄模式實(shí)現(xiàn)過關(guān)類游戲功能,結(jié)合實(shí)例形式詳細(xì)分析了java備忘錄模式的概念、原理及其在過關(guān)類游戲中的具體應(yīng)用方法,需要的朋友可以參考下2018-04-04
本文通過理論、用法、實(shí)例詳細(xì)說明了JAVA IO的使用，大家參考其中的實(shí)例代碼實(shí)現(xiàn)自己的JAVA IO程序2013-11-11
這篇文章主要介紹了java中使用數(shù)組進(jìn)行模擬加密的方法,需要的朋友可以參考下2014-08-08
這篇文章主要介紹了JAVA線程同步實(shí)例教程,在Java程序設(shè)計(jì)中有著非常廣泛的應(yīng)用,需要的朋友可以參考下2014-08-08
這篇文章主要介紹了JavaWeb BeanUtils信息類原理詳解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-02-02