
精选·Kafka与消息队列2026-07-13
Kafka 消息积压怎么排查?怎么快速扩容消费?
以 lag 监控为入口,按"消费慢、分区不均、Rebalance 频繁、下游瓶颈"四类根因排查,给出临时扩容、加消费者、加分区、跳过历史消息的分级处置方案。
91学AI·7 阅读
共 2 篇文章

以 lag 监控为入口,按"消费慢、分区不均、Rebalance 频繁、下游瓶颈"四类根因排查,给出临时扩容、加消费者、加分区、跳过历史消息的分级处置方案。

讲清 Flink 基于信用额度(credit-based)的反压传导原理,以及用 Web UI 指标、线程栈、Metrics 定位反压根因的完整排查套路。