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ù)造成影響(雖然我自己測試的結(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)文章
SpringBoot項(xiàng)目整合mybatis的方法步驟與實(shí)例
今天小編就為大家分享一篇關(guān)于SpringBoot項(xiàng)目整合mybatis的方法步驟與實(shí)例,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧2019-03-03java實(shí)現(xiàn)最短路徑算法之Dijkstra算法
這篇文章主要介紹了java實(shí)現(xiàn)最短路徑算法之Dijkstra算法, Dijkstra算法是最短路徑算法中為人熟知的一種,是單起點(diǎn)全路徑算法,有興趣的可以了解一下2017-10-10Java中的可變參數(shù)常見用法實(shí)例總結(jié)
這篇文章主要介紹了Java中的可變參數(shù)常見用法,結(jié)合實(shí)例形式總結(jié)分析了java可變參數(shù)的常見功能、使用方法及相關(guān)操作注意事項(xiàng),需要的朋友可以參考下2019-10-10生成8位隨機(jī)不重復(fù)的數(shù)字編號(hào)的方法
生成隨機(jī)不重復(fù)的數(shù)字編號(hào)在某些情況下也會(huì)用到,本文以生成8位隨機(jī)不重復(fù)的數(shù)字編號(hào)為例與大家分享下具體的實(shí)現(xiàn)過程,感興趣的朋友可以參考下2013-09-09微服務(wù)之間如何通過feign調(diào)用接口上傳文件
這篇文章主要介紹了微服務(wù)之間如何通過feign調(diào)用接口上傳文件的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-06-06IDEA啟動(dòng)報(bào)錯(cuò)Internal?error.?Please?refer?to?https://jb.gg/i
這篇文章主要介紹了IDEA啟動(dòng)報(bào)錯(cuò)Internal?error.?Please?refer?to?https://jb.gg/ide/critical-startup-errors解決辦法,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-04-04