问题现象:
在启动kafka集群之后,发现部分机器上的kafka进程没有起起来。
原因定位:
通过在没有起起来的机器上查看kafka启动日志发现如下报错信息:
ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentBrokerIdException: Configured broker.id 1 doesn’t match stored broker.id 0 in meta.properties. If you moved your data, make sure your configured broker.id matches. If you intend to create a new broker, you should remove all data in your data directories (log.dirs).
at kafka.server.KafkaServer.getBrokerIdAndOfflineDirs(KafkaServer.scala:686)
at kafka.server.KafkaServer.startup(KafkaServer.scala:209)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)
at kafka.Kafka$.main(Kafka.scala:75)
at kafka.Kafka.main(Kafka.scala)
根因:
在本次启动kafka之前,我是用的0.9.0.0版本,本次在升级到2.1.1版本之后只是修改了配置文件server.properties,并没有清空
log.dirs=/home/hadoop/app/kafka_2.11-2.1.1/kafka-logs目录下旧版本的文件数据。
解决:
把该目下的旧版本数据信息清空掉,重启zookeeper和kafka:问题解决。