消息队列（MQ）堵塞是生产环境中常见的问题，疏通的核心思路是先恢复消费能力、再清理积压、最后查根因防复发。下面按“应急 → 清理 → 根治”给你一套通用方案，适用于 Kafka / RocketMQ / RabbitMQ / Pulsar 等主流 MQ。
最常见、最有效：
max.poll.records 调大consumeMessageBatchMaxSize 调大这是大厂处理 Kafka/RocketMQ 百万级积压的标准做法
| 原因 | 表现 | 解决 |
|---|---|---|
| 消费逻辑慢 | CPU 高、RT 长 | 异步化、批处理 |
| 数据库慢 | SQL 锁等待 | 优化 SQL、限流 |
| 第三方接口慢 | 超时 | 降级、超时断开 |
| 消费者挂了 | Lag 只增不减 | 重启 + 监控 |
| 分区数太少 | 消费并行度低 | 增加分区 |
| 消息体太大 | 网络/磁盘瓶颈 | 压缩、瘦身 |
为了给你更精准的方案，可以补充：
我可以直接给你具体参数和代码级操作。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
