1 前言

一个问题，一篇文章，一出故事。
今天安装Apache Kafka，不慎给了已经使用的broker.id，修正后出现启动异常，详细报错如下，

#...
[2026-03-18 15:02:17,347] ERROR Error while creating ephemeral at /brokers/ids/3, node already exists and owner '-27894856291450870' does not match current session '-27878599219150828' (kafka.zk.KafkaZkClient$CheckedEphemeral)
[2026-03-18 15:02:17,365] ERROR [KafkaServer id=3] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists
        at org.apache.zookeeper.KeeperException.create(KeeperException.java:126)
        at kafka.zk.KafkaZkClient$CheckedEphemeral.getAfterNodeExists(KafkaZkClient.scala:1904)
        at kafka.zk.KafkaZkClient$CheckedEphemeral.create(KafkaZkClient.scala:1842)
        at kafka.zk.KafkaZkClient.checkedEphemeralCreate(KafkaZkClient.scala:1809)
        at kafka.zk.KafkaZkClient.registerBroker(KafkaZkClient.scala:96)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:319)
        at kafka.Kafka$.main(Kafka.scala:109)
        at kafka.Kafka.main(Kafka.scala)
#...
[2026-03-18 15:02:18,855] ERROR Exiting Kafka. (kafka.Kafka$)
#...

2 最佳实践

2.1 测试环境

如何部署Oracle Linux 10.x Apache Kafka 3.0.0集群？

2.2 修复方案

2.2.1 连接zookeeper

zookeeper-client -server hd01.cmdschool.org

2.2.2 查看broker.id设置

[zk: hd01.cmdschool.org(CONNECTED) 0] get /brokers/ids/3

可见如下显示，

{"features":{},"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://hd03.cmdschool.org:9092"],"jmx_port":-1,"port":9092,"host":"hd03.cmdschool.org","version":5,"timestamp":"1773816065980"}
cZxid = 0x200000261
ctime = Wed Mar 18 14:41:05 CST 2026
mZxid = 0x200000261
mtime = Wed Mar 18 14:41:05 CST 2026
pZxid = 0x200000261
cversion = 0
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0xff9ce5c6a7b0000a
dataLength = 226
numChildren = 0

2.2.3 删除错误的broker.id设置

[zk: hd01.cmdschool.org(CONNECTED) 1] rmr /brokers/ids/3
[zk: hd01.cmdschool.org(CONNECTED) 2]