一句话答案

紧急处理：扩消费者实例 + 临时调大消费线程 + 跳过非核心消息；根治：优化消费逻辑/合理设置 Partition 数。

核心要点

紧急处理：

1. 扩容消费者实例(Kafka需先扩Partition)
2. 临时调大消费线程数
3. 跳过/转存非核心消息
4. 新建临时Topic分流

根治： 优化消费逻辑(批量处理/异步化) / 合理设置Partition数

追问与易错

追问方向：

• 这个概念在你的项目中是怎么应用的？
• 和相关技术/方案相比有什么优劣？
• 如果出了问题你会怎么排查？

易错点：

• ❌ 只知道概念不知道原理——面试官会追问底层实现
• ❌ 缺乏实际使用经验——结合项目场景回答更有说服力

💡 记忆锚点

消息积压 = 高速公路堵车。急救：加车道(扩消费者)+提速(加线程)+让非急救车下高速(跳过非核心消息)。根治：修路(优化消费逻辑)+合理规划车道数(Partition数)。记住Kafka扩消费者前必须先扩Partition。