×

如何正确更改kafka broker id

admin admin 发表于2018-08-26 00:48:50 浏览1737 评论0

抢沙发发表评论

版本:kafka 0.9.0.0 
操作:修改server.properties中的broker id 
一般会得到如下错误:

[2018-08-26 00:41:54,540] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentBrokerIdException: Configured broker.id 2 doesn't match stored broker.id 1 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:670)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:209)
        at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)
        at kafka.Kafka$.main(Kafka.scala:92)
        at kafka.Kafka.main(Kafka.scala)
[2018-08-26 00:41:54,543] INFO shutting down (kafka.server.KafkaServer)


更正办法:手动修改meta.properties文件,在配置的log.dir下

vi /tmp/kafka-logs/meta.properties

So, 如果你想改kafka的broker id,比如第一遍写错了,应该遵循两个步骤: 
1. 改server.prorperties文件配置; 
2. 改meta.properties,默认情况下,应该在/tmp/kafka-logs目录下; 
同时需注意数据存在多个目录时,需要修改多个目录的meta.propertie。


分享到:

群贤毕至

访客