重設消費位點是指改變訂閱者當前的消費位置。當消費者出現故障或者消費錯誤資料時,您可通過重設消費位點將消費位置復原到之前的某個位點或者指定分區位點,重新開始消費。您也可以將消費位置移動至最新位點,暫時不處理堆積的訊息。
前提條件
已停止所有Consumer用戶端(雲訊息佇列 Kafka 版不支援線上重設消費位點)。
在停止Consumer用戶端後,需要經過ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG
配置的時間(預設10000 ms),服務端才認為Consumer真正下線。
背景資訊
雲訊息佇列 Kafka 版支援以下重設消費位點方式:
從最新位點開始消費:不再消費Broker上堆積的訊息,將消費位點重設到最新的位置。
說明堆積的訊息本身並不會因此被刪除,改變的只是消費位點。
指定時間點開始消費:將消費位點重設到過去的某個時間點(該時間點以Topic的訊息儲存時間為準)。
按分區消費位點進行重設:如果只有少量分區產生訊息堆積,可以僅重設指定分區的消費位點,避免重複消費其他分區中已正確處理的訊息。
操作步驟
在概览頁面的资源分布地區,選擇地區。
在实例列表頁面,單擊目標執行個體名稱。
在左側導覽列,單擊Group 管理。
在Group 管理頁面,單擊目標Group ID。
在重設Group的消費位點面板,瞭解其前提条件,設定重設策略。
設定重置所有 Topic。
單擊是,重設所有Topic的消費位點。
單擊否,在Topic文字框輸入需要重設Topic的名稱。
設定重置方式。
單擊从最新位点开始消费,將消費位點指定到最新的位置,單擊確定。
單擊从指定时间点的位点开始消费,在时间点文字框,單擊,從指定時間點的位點開啟消費功能,單擊確定。
單擊按分区消费位点进行重置,在目標資料分割所在行, 消费位点文字框輸入開始消費位點值,單擊確定。
在提示對話方塊,確認提示資訊,單擊確認。
相關文檔
如果您希望通過API來重設消費位點,請參見UpdateConsumerOffset - 重設消費者組的消費位點。
重設完成後,您可以通過查看消費狀態來擷取最新的消費位點資訊。