我是小米，一个喜欢分享技术的29岁程序员。如果你喜欢我的文章，欢迎关注我的微信公众号“软件求生”，获取更多技术干货！​​​​​​​

Hello, 各位亲爱的读者朋友们！我是你们的小米，一个积极活泼的技术分享达人，今天我们要聊聊一个大家在分布式系统中经常遇到的棘手问题——积压消费。

在我们的日常开发中，随着业务量的增加，消息队列中的数据量也会大幅度增长。如果消费端处理速度跟不上，就会造成消息积压，严重影响系统的稳定性和响应速度。那么，我们该如何解决这个问题呢？今天，我将通过三个步骤为大家详细讲解如何解决积压消费的问题：

• 修复consumer，使其具备消费能力，并且扩容N台
• 写一个分发的程序，将Topic均匀分发到临时Topic中
• 同时起N台consumer，消费不同的临时Topic

快来和我一起看看具体的操作步骤吧！

修复consumer，使其具备消费能力，并且扩容N台

首先，我们需要确保消费者（consumer）具备正常的消费能力。如果consumer存在bug或者性能瓶颈，就会导致消息消费速度慢。这里我们可以从以下几个方面进行优化：

修复Bug

• 检查日志和监控，找到consumer