Kafka 延迟与堆积排查手册

核心指标消费滞后（Consumer Lag）：消费位点与最新位点差值。分区与并发：分区数决定消费者并行度，上限为分区数。复制与 ISR：副本同步集合影响可用性与消息提交。排查路径观察滞后曲线与消费速率，定位是否处理能力不足或上游突增。检查消费者并发与分区分配是否均衡；必要时扩分区并重平衡。评估消息大小与批量参数，优化批处理与提交策略。稳定性建议隔离关键 Topic 与消费组，避免相互影响。建立告警阈值（滞后、拒绝率、错误码），配合限流与退避策略。通过指标与日志联动，复盘堆积根因并固化变更流程。