您的位置:首页 > 其它

如何正确更改kafka broker id

2016-06-29 15:21 344 查看
版本:kafka 0.9.0.0

操作:修改server.properties中的broker id

一般会得到如下错误:

[2016-06-29 15:05:29,127] FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentBrokerIdException: Configured brokerId 2 doesn't match stored brokerId 1 in meta.properties
at kafka.server.KafkaServer.getBrokerId(KafkaServer.scala:630)
at kafka.server.KafkaServer.startup(KafkaServer.scala:175)
at io.confluent.support.metrics.SupportedServerStartable.startup(SupportedServerStartable.java:99)
at io.confluent.support.metrics.SupportedKafka.main(SupportedKafka.java:45)


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

vi ../kafka_data/meta.properties


So, 如果你想改kafka的broker id,比如第一遍写错了,应该遵循两个步骤:

1. 改server.prorperties文件配置;

2. 改meta.properties,默认情况下,应该在/tmp/kafka-logs目录下;

同时需注意数据存在多个目录时,需要修改多个目录的meta.propertie。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  kafka