栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.c

ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.c

kafka启动时报错如下:

[2021-12-28 23:35:02,165] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID eq9F2UfWTVqmKCEial0hrw doesn't match stored clusterId Some(43bjl8_0Qoe6Pw3psZjroA) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.
	at kafka.server.KafkaServer.startup(KafkaServer.scala:218)
	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
	at kafka.Kafka$.main(Kafka.scala:84)
	at kafka.Kafka.main(Kafka.scala)

报错截图如下:

大概意思如下:

集群 ID eq9F2UfWTVqmKCEial0hrw 与 meta.properties 中存储的 clusterId 
Some(43bjl8_0Qoe6Pw3psZjroA) 不匹配。
 代理正在尝试加入错误的集群。 配置的zookeeper.connect 可能是错误的。

更正一下,这里这个错误和Zookeeper是没有关系的,这个报错的意思集群id不匹配,即当前启动的id和 meta.properties里面的id不匹配,造成这样的原因通常是你为正确关闭kafka或者是关闭时出现异常导致的。

[lqs@bdc112 datas]$ pwd
/home/lqs/module/kafka_2.11-2.4.1/datas



就是这个文件里面的cluster.id不一样导致的,您只需要改成和您报错的那个id一样就可以了(不是报错括号里面的那个id哈,是第一个id号哈)

像我这样改好并保存就可以。

注意:如果您的集群都出现了这样的错误,记得每一个都去改,或群发一下也可以;

如果担心数据的丢失,有一种最简单的办法,即把kafka相关的datas目录和logs目录删除,再来重启kafka即可。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/689984.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号