本文介绍了启动多个Kafka代理失败-配置的brokerId与存储的brokerId不匹配的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
尝试启动多个不同brokerId的Kafka Broker时,一个是默认的server.properties
,另一个是更改了2行的serverTest.properties
,分别是broker.id=1
和listeners=PLAINTEXT://localhost:6000
。睡觉是相同的默认设置。我先启动ZooKeeper,然后启动默认的Kafkaserver.properties
,然后启动serverTest.properties
时出现以下异常:kafka.common.InconsistentBrokerIdException: Configured brokerId 1 doesn't match stored brokerId 0 in meta.properties
。我的理解是,下面的代码实际上应该会启动多个节点,就像我在教程中看到的其他节点一样。我用的是卡夫卡9.0。
推荐答案
编辑CONFIG/serverTest.properties并替换现有配置值,如下所示:
broker.id=2
listeners=PLAINTEXT://9093
log.dirs=/tmp/kafka-logs-2
如果您需要第三个经纪人:
cp config/server.properties config/server3.properties
编辑config/server3.properties并替换现有配置值,如下所示:
broker.id=3
listeners=PLAINTEXT://:9094
log.dirs=/tmp/kafka-logs-3
如果您在不同的计算机上运行,则必须更改
advertised.listeners=PLAINTEXT://192.168.x.x:<port>
否则,如果您在同一台VMware计算机上运行,则只应如上所述更改端口和log.dir
这篇关于启动多个Kafka代理失败-配置的brokerId与存储的brokerId不匹配的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!