重置消費位點是指改變訂閱者當前的消費位置。當消費者出現故障或者消費錯誤數據時,您可通過重置消費位點將消費位置回滾到之前的某個位點或者指定分區位點,重新開始消費。您也可以將消費位置移動至最新位點,暫時不處理堆積的消息。
前提條件
已停止所有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 - 重置消費者組的消費位點。
重置完成后,您可以通過查看消費狀態來獲取最新的消費位點信息。