记kafka启动失败

wuxuan.chai

发布于：2021年1月18日

场景

在项目开发中，需要使用到kafka，但是无论如何本地环境的kafka都无法启动，zookeeper状态是正常的，kafka就是起不来，导致项目的日志消费的任务一直阻塞。重新启动会发生异常：InconsistentClusterIdException。

异常的信息

ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID F-bhGf-3T1qgjuQ0c1wCRw doesn't match stored clusterId Some(FO2XIwDrSSiJSeWo4B80hQ) 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:223)
	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)
	at kafka.Kafka$.main(Kafka.scala:82)
	at kafka.Kafka.main(Kafka.scala)
    ....

原因分析及解决方案

kafka的配置日志路径，用来保存kafka的执行过程中的信息，如果kafka异常关闭，日志记录就会出现异常，会把当时的情况记录在meta.properties文件中，重启时，此文件会对启动产生影响。原因是，里面记录了borker 和cluster-id,导致的报错。

解决方式

清空日志目录【日志不重要或可以容忍日志丢失】。
调整日志目录【需要修改配置】。
删除日志目录下的meta.properties文件。

Apache SkyWalking 单机版测试

博客内容遵循署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0) 协议

本文永久链接是：https://cha1yi.github.io/dist/2021/01/18/kafka%E9%94%99%E8%AF%AF%E5%A4%84%E7%90%86%E8%A7%A3%E5%86%B3%E6%80%BB%E7%BB%93/