定位命令
定位命令
kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-replicated-partitions
kafka-topics.sh --bootstrap-server localhost:9092 --describe --unavailable-partitions
# 对单个 broker 看运行与磁盘状态
systemctl status kafka
df -h /data/kafka- 1. 掉线 Broker：优先拉起进程并观察 ISR 自愈
- 2. 磁盘/网络异常：修复后副本会自动追平
- 3. 长期不恢复：用 reassign 把副本迁到健康节点
- 4. 全部副本不可用且业务可接受丢数据：才用 UNCLEAN 选举
unclean 选举会丢未同步数据；执行前必须确认业务后果并留记录。