Kafka 延迟与堆积排查手册

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