重置消費(fèi)位點(diǎn)
重置消費(fèi)位點(diǎn)是指改變訂閱者當(dāng)前的消費(fèi)位置。當(dāng)消費(fèi)者出現(xiàn)故障或者消費(fèi)錯(cuò)誤數(shù)據(jù)時(shí)，您可通過重置消費(fèi)位點(diǎn)將消費(fèi)位置回滾到之前的某個(gè)位點(diǎn)或者指定分區(qū)位點(diǎn)，重新開始消費(fèi)。您也可以將消費(fèi)位置移動(dòng)至最新位點(diǎn)，暫時(shí)不處理堆積的消息。
前提條件
已停止所有Consumer客戶端（云消息隊(duì)列 Kafka 版不支持在線重置消費(fèi)位點(diǎn)）。
在停止Consumer客戶端后，需要經(jīng)過ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的時(shí)間（默認(rèn)10000 ms），服務(wù)端才認(rèn)為Consumer真正下線。
背景信息
云消息隊(duì)列 Kafka 版支持以下重置消費(fèi)位點(diǎn)方式：
從最新位點(diǎn)開始消費(fèi)：不再消費(fèi)Broker上堆積的消息，將消費(fèi)位點(diǎn)重置到最新的位置。
說明堆積的消息本身并不會(huì)因此被刪除，改變的只是消費(fèi)位點(diǎn)。
指定時(shí)間點(diǎn)開始消費(fèi)：將消費(fèi)位點(diǎn)重置到過去的某個(gè)時(shí)間點(diǎn)（該時(shí)間點(diǎn)以Topic的消息存儲(chǔ)時(shí)間為準(zhǔn)）。
按分區(qū)消費(fèi)位點(diǎn)進(jìn)行重置：如果只有少量分區(qū)產(chǎn)生消息堆積，可以僅重置指定分區(qū)的消費(fèi)位點(diǎn)，避免重復(fù)消費(fèi)其他分區(qū)中已正確處理的消息。
操作步驟
在概覽頁面的資源分布區(qū)域，選擇地域。
在實(shí)例列表頁面，單擊目標(biāo)實(shí)例名稱。
在左側(cè)導(dǎo)航欄，單擊Group 管理。
在Group 管理頁面，找到目標(biāo)Group，在其右側(cè)操作列，選擇。
在重置Group的消費(fèi)位點(diǎn)面板，了解其前提條件，設(shè)置重置策略。
設(shè)置重置所有 Topic。
單擊是，重置所有Topic的消費(fèi)位點(diǎn)。
單擊否，在Topic文本框輸入需要重置Topic的名稱。
設(shè)置重置方式。
單擊從最新位點(diǎn)開始消費(fèi)，將消費(fèi)位點(diǎn)指定到最新的位置，單擊確定。
單擊從指定時(shí)間點(diǎn)的位點(diǎn)開始消費(fèi)，在時(shí)間點(diǎn)文本框，單擊
，從指定時(shí)間點(diǎn)的位點(diǎn)開啟消費(fèi)功能，單擊確定。單擊按分區(qū)消費(fèi)位點(diǎn)進(jìn)行重置，在目標(biāo)分區(qū)所在行， 消費(fèi)位點(diǎn)文本框輸入開始消費(fèi)位點(diǎn)值，單擊確定。
在提示對(duì)話框，確認(rèn)提示信息，單擊確認(rèn)。
相關(guān)文檔
如果您希望通過API來重置消費(fèi)位點(diǎn)，請(qǐng)參見UpdateConsumerOffset - 重置消費(fèi)者組的消費(fèi)位點(diǎn)。
重置完成后，您可以通過查看消費(fèi)狀態(tài)來獲取最新的消費(fèi)位點(diǎn)信息。