四步排查命令
四步排查命令
# 1) 组级概览：每分区 lag
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--describe --group order-consumer
# 2) 成员与分配是否正常
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--describe --group order-consumer --members --verbose
# 3) 集群侧副本健康
kafka-topics.sh --bootstrap-server localhost:9092 --describe --under-replicated-partitions现象与方向
| 现象 | 大概率原因 | 动作 |
|---|---|---|
| 全部区均匀上涨 | 消费能力不足或下游变慢 | 扩容分区/消费者，优化下游写入 |
| 个别分区独高 | 热 key 导致分区倾斜 | 调整分区键或拆分热点 |
| lag 锯齿状波动 | 频繁再均衡或处理超时 | 查 max.poll.interval.ms 与处理耗时 |
| 消费者无分配 | 分区数/组名/订阅不一致 | 核对分区数与客户端配置 |
生产突增（流量翻倍）与消费变慢要区分：看生产端速率曲线能避免错误扩容。