本文介绍了启动多个Kafka代理失败-配置的brokerId与存储的brokerId不匹配的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

尝试启动多个不同brokerId的Kafka Broker时,一个是默认的server.properties,另一个是更改了2行的serverTest.properties,分别是broker.id=1listeners=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不匹配的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

05-20 21:48