全部產品
Search
文件中心

ApsaraMQ for Kafka:重設消費位點

更新時間:Dec 27, 2024

重設消費位點是指改變訂閱者當前的消費位置。當消費者出現故障或者消費錯誤資料時,您可通過重設消費位點將消費位置復原到之前的某個位點或者指定分區位點,重新開始消費。您也可以將消費位置移動至最新位點,暫時不處理堆積的訊息。

前提條件

已停止所有Consumer用戶端(雲訊息佇列 Kafka 版不支援線上重設消費位點)。

重要

在停止Consumer用戶端後,需要經過ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的時間(預設10000 ms),服務端才認為Consumer真正下線。

背景資訊

雲訊息佇列 Kafka 版支援以下重設消費位點方式:

  • 從最新位點開始消費:不再消費Broker上堆積的訊息,將消費位點重設到最新的位置。

    說明

    堆積的訊息本身並不會因此被刪除,改變的只是消費位點。

  • 指定時間點開始消費:將消費位點重設到過去的某個時間點(該時間點以Topic的訊息儲存時間為準)。

  • 按分區消費位點進行重設:如果只有少量分區產生訊息堆積,可以僅重設指定分區的消費位點,避免重複消費其他分區中已正確處理的訊息。

操作步驟

  1. 登入雲訊息佇列 Kafka 版控制台

  2. 概览頁面的资源分布地區,選擇地區。

  3. 实例列表頁面,單擊目標執行個體名稱。

  4. 在左側導覽列,單擊Group 管理

  5. Group 管理頁面,單擊目標Group ID

  6. Group 詳情頁面,單擊重置消费位点

  7. 重設Group的消費位點面板,瞭解其前提条件,設定重設策略。

    1. 設定重置所有 Topic

      • 單擊,重設所有Topic的消費位點。

      • 單擊,在Topic文字框輸入需要重設Topic的名稱。

    2. 設定重置方式

      • 單擊从最新位点开始消费,將消費位點指定到最新的位置,單擊確定

      • 單擊从指定时间点的位点开始消费,在时间点文字框,單擊日曆,從指定時間點的位點開啟消費功能,單擊確定

      • 單擊按分区消费位点进行重置,在目標資料分割所在行, 消费位点文字框輸入開始消費位點值,單擊確定

  8. 提示對話方塊,確認提示資訊,單擊確認

相關文檔