一、核心错误分析

ERROR Error while creating ephemeral at /brokers/ids/1, node already exists and owner does not match
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists

问题本质：ZooKeeper中已存在ID为1的broker节点，但当前会话无法访问
可能原因：
1. 之前的Kafka实例未正常关闭，残留了临时节点
2. 多个Kafka实例使用相同的broker.id注册
3. ZooKeeper会话过期但节点未自动清理

二、解决方案

1. 方案一：清理ZooKeeper中的残留节点（推荐）

# 连接到ZooKeeper客户端
/usr/local/lib/zookeeper/bin/zkCli.sh -server inzoo-collect-01:2181# 查看/brokers/ids节点下的内容
[zk: inzoo-collect-01:2181(CONNECTED) 0] ls /brokers/ids# 示例输出（可能包含1,2,3等节点）
[1, 2, 3]# 删除冲突的节点（以ID=1为例）
[zk: inzoo-collect-01:2181(CONNECTED) 1] delete /brokers/ids/1# 退出客户端
[zk: inzoo-collect-01:2181(CONNECTED) 2] quit

2. 方案二：修改当前Kafka节点的broker.id

# 编辑server.properties
vi /usr/local/lib/kafka/config/server.properties# 修改broker.id为未使用的ID（如4）
broker.id=4# 重启Kafka服务
systemctl restart kafka

3. 方案三：重启ZooKeeper集群（清理所有临时节点）

# 停止所有ZooKeeper节点
systemctl stop zookeeper# 等待30秒确保所有节点停止
sleep 30# 启动所有ZooKeeper节点
systemctl start zookeeper# 验证ZooKeeper状态
systemctl status zookeeper

三、深度排查步骤

1. 检查ZooKeeper中的节点所有者

# 连接到ZooKeeper客户端
zkCli.sh -server inzoo-collect-01:2181# 查看节点详细信息
[zk: localhost:2181(CONNECTED) 0] stat /brokers/ids/1# 关键信息：
# cZxid = 0x123456789  # 创建事务ID
# mZxid = 0x123456789  # 修改事务ID
# ephemeralOwner = 0x144162835911081984  # 临时节点所有者

2. 检查冲突节点的所有者是否活跃

# 在ZooKeeper客户端中执行
[zk: localhost:2181(CONNECTED) 1] get /brokers/ids/1# 如果返回空值或旧数据，说明节点为残留节点，可安全删除

四、预防措施

1. 正确关闭Kafka服务

# 使用官方脚本关闭
/usr/local/lib/kafka/bin/kafka-server-stop.sh# 或通过systemd
systemctl stop kafka

2. 配置ZooKeeper自动清理

# 在zoo.cfg中添加
autopurge.snapRetainCount=3
autopurge.purgeInterval=1

3. 确保broker.id唯一

# 在每个节点上检查
grep broker.id /usr/local/lib/kafka/config/server.properties# 节点1: broker.id=1
# 节点2: broker.id=2
# 节点3: broker.id=3

五、验证修复

1. 重启Kafka服务

systemctl restart kafka# 查看日志确认注册成功
journalctl -u kafka | grep "Registered broker"

2. 检查ZooKeeper节点

zkCli.sh -server inzoo-collect-01:2181# 查看节点所有者是否更新
[zk: localhost:2181(CONNECTED) 0] stat /brokers/ids/1# 预期输出：ephemeralOwner为当前会话ID

3. 验证Kafka集群状态

# 查看集群中的broker
/usr/local/lib/kafka/bin/kafka-broker-api-versions.sh --bootstrap-server inzoo-collect-01:9092# 示例输出
172.16.0.1:9092, controller: 1
172.16.0.2:9092, controller: 1
172.16.0.3:9092, controller: 1