首先要找到是什么原因导致的消息堆积,是Producer太多了,Consumer太少了导致的还是说 其他情况,总之先定位问题。

然后看下消息消费速度是否正常,正常的话,可以通过上线更多consumer临时解决消息堆积 问题。