0


解决kafka启动成功后然后又关闭了的问题

问题:

[2021-05-10 11:22:43,263] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)

kafka.common.InconsistentClusterIdException: The Cluster ID VLPFfY-WQkWmK7X9_C1aHQ doesn't match stored clusterId Some(0TVA9OzOTzCGMTqY50sBKA) 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)

原因:可能是meta.properties中cluster_id值有误。

解决方法:

先移动到kafka的log.Dirs路径

如果不知道的自己的kafka的log.Dirs路径,可以去kafka的config目录下的servers.properties

cat /opt/module/kafka/config/server.properties

找到log.Dirs目录后

cp meta.properties meta.properties_bak

修改meta.properites中的cluster.id值

如果不知道cluster.id值,可以去kafka的日志目录中查看报错信息,里面有cluster_id

修改完之后,在重新启动kakfa就可以了。

标签: kafka scala java

本文转载自: https://blog.csdn.net/JiaXingNashishua/article/details/126681973
版权归原作者 大数据阿嘉 所有, 如有侵权,请联系我们删除。

“解决kafka启动成功后然后又关闭了的问题”的评论:

还没有评论