消息大量积压时怎样处理？
先自己想一想，再看参考要点
参考要点
- 先区分生产突增（峰值后可自然消化）还是消费变慢（下游变慢、反复重试、频繁重平衡），先修复消费变慢的原因，失败消息转入死信队列
- 扩容消费者（Kafka 普通消费者组、RocketMQ 4.x 中超过分区或队列数的消费者会空闲），或批量写库、线程池并行（同一 key 交给同一线程）
- 分区不够时转发到分区更多的新主题，不重要的消息降级跳过
- 积压接近保留时间（Kafka 默认 7 天）前先转存
学习站：先用面试题自评定级，按水平和面试日期排出每天的计划，自评过的题按间隔复习。免费、无需注册，记录只保存在自己的浏览器中。