由于consumer消费者出现了故障,message没有被及时消费,导致topic挤压了几百万甚至几千万的数据。
这种情况的解决方案通常是先修复consumer,再迅速消费完积压的消息。
1. 修复consumer程序,并停止消费
2. 新建数倍的topic或者数倍的queue
3. 积压的消息简单消费处理之后均匀写入新建的queue。注意消费速度,新建queue的数量,目的迅速消费积压的message
4. 临时调用数倍的服务器部署consumer程序,对queue进行消费
5. 处理完成之后恢复原来的部署架构