判斷消息堆積是否屬于正常情況

如果發現Group中出現消息堆積，請參見下列步驟，判斷消息堆積是否屬于正常情況：

1. 登錄云消息隊列 Kafka 版控制臺。

2. 在頂部菜單欄，選擇地域。

3. 在左側導航欄，單擊實例列表。

4. 在實例列表頁面，單擊目標實例名稱。

5. 在實例詳情頁面，單擊左側菜單欄中的Group管理。

6. 在Group管理頁面，找到目標Group，在其操作列，選擇更多>消費狀態 。

7. 在消費狀態頁簽，每間隔1分鐘記錄一次各個Topic分區的最近消費時間、堆積量和消息位點，然后進行下列判斷：

   說明

   消息位點可通過單擊詳情按鈕進行查看。

   • 最近消費時間與當前時間接近，并且堆積量保持在一個穩定的數值之間波動，沒有持續擴大。 說明客戶端一直在拉取最新消息，沒有消息堆積，屬于正常情況。

     說明

     消息堆積量會根據消息量、消費端位點提交頻率的變化而變化，數值大并不一定表示堆積。例如，某個Topic的發送頻率為10000 tps，消費端位點提交頻率為1 s提交1次，正常情況下展示的堆積量可能會一直在10000左右波動，但并非意味著消息堆積了。

   • 堆積量逐步擴大，并且消息位點一直不變。 客戶端的消費線程因為某些原因卡住，沒有繼續消費，也沒有繼續向服務端提交位點，屬于異常情況，即消息的確堆積了。請參見下文的消息堆積的處理方式章節進行處理。

   • 堆積量逐步擴大，同時消費位點在前進。 說明客戶端還在消費中，但是消息的消費速度慢于消息的發送速度。由于消息是客戶端主動從服務端批量拉取，客戶端消費流程中的步驟1一般不會是消費的瓶頸。此時，需要排查步驟2的消費耗時，請參見下文的消息堆積的處理方式章節進行處理。

     說明

     消息堆積大多是消費速度過慢或者消費線程阻塞造成的，建議不要在消費邏輯中有太多耗時的操作。

   • 分區消息堆積，下游消費卻無異常。下游可能采用了assign消費模式，位點是您自己管理的。這種情況下雖然顯示了堆積，實際上您可能已經消費了，但是沒有提交位點。建議您及時手動提交位點解決消息堆積問題。

消息堆積的處理方式

經過上述判斷，確認消息的確存在堆積情況時，建議打印消息的消費耗時，或者根據堆棧信息查看線程執行情況。根據以下方案適當調整以加快消息的消費速度，避免出現消息堆積。

相關文檔

• 關于Jstack的更多信息，請參見Oracle JDK中Jstack命令的介紹。

• 更多常見問題，請參見云消息隊列 Kafka 版使用中的常見問題。