由于上一次暴力关闭kafka,出现了以下错误
ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID mJ-Qdb_wTIiZoaVCcTawRQ doesn't match stored clusterId Some(z0pCsxM1Rr661m166trFoA) 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:220)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
at kafka.Kafka$.main(Kafka.scala:84)
at kafka.Kafka.main(Kafka.scala)
原因:
这应该是2.4.0的问题
Kafka过去是与Zookeeper的其他实例一起启动的,因此在其中注册了旧的Zookeeper ID。
解决:
解决了很久最后在一外国论坛找到点头绪
- 在Kafka config目录中,打开kafka config属性文件,让server.properties查找具有参数log.dirs =的日志路径目录,然后转到日志路径目录并在其中找到文件meta.properties。打开文件meta.properties并更新cluster.id =或从日志路径目录中删除此文件或所有日志文件,然后重新启动kafka。(这个方法并没有解决我的问题)
- 修改kafka config目录下sercer.properties 修改了log.dir的位置重启成功解决,之前日志全部丢失代价很大