由于consumer消費者出現了故障,message沒有被及時消費,導致topic擠壓了幾百萬甚至幾千萬的數據。
這種情況的解決方案通常是先修復consumer,再迅速消費完積壓的消息。
1. 修復consumer程序,并停止消費
2. 新建數倍的topic或者數倍的queue
3. 積壓的消息簡單消費處理之后均勻寫入新建的queue。注意消費速度,新建queue的數量,目的迅速消費積壓的message
4. 臨時調用數倍的服務器部署consumer程序,對queue進行消費
5. 處理完成之后恢復原來的部署架構