訊息消費積壓問題排查實戰

在 rocketmq 訊息消費方面乙個最常見的問題是訊息積壓，其現象如下圖所示：

所謂的訊息積壓：就是 broker 端當前佇列有效資料最大的偏移量（brokeroffset）與訊息消費端的當前處理進度（consumeroffset）之間的差值，即表示當前需要消費但沒有消費的訊息。

專案組遇到訊息積壓問題通常第一時間都會懷疑是 rocketmq broker 的問題，會第一時間聯絡到訊息中介軟體的負責，訊息中介軟體負責人當然會首先排查 broker 端的異常，但根據筆者的境遇，此種情況通常是消費端的問題，反而是訊息傳送遇到的問題更有可能是 broker 端的問題，當然筆者也有方法進行舉證，服務端的診斷方法稍後會給出，這裡基本可以採用模擬法，因為乙個 topic 通常會被多個消費端訂閱，我們只要看看其他消費組是否也積壓，例如如下圖所示：