重置消費(fei)進度即修改消費(fei)者的消費(fei)位置。
說明
重置消費(fei)進度(du)可能會(hui)導(dao)致重復消費(fei)，請謹慎操作。
前提條件
Kafka實例不(bu)支持在(zai)線(xian)重置(zhi)消費(fei)進(jin)(jin)度(du)，請(qing)先將(jiang)待(dai)重置(zhi)消費(fei)進(jin)(jin)度(du)的消費(fei)組停止消費(fei)，然后(hou)重置(zhi)消費(fei)進(jin)(jin)度(du)。
操作步驟
步驟 1 登錄管(guan)理控(kong)制(zhi)臺。
步驟 2 在管理控制臺右上角單擊
，選擇區域。
說明請選擇Kafka實(shi)例所在的區域。
步驟 3 在管理控制臺左上角單擊
，選擇“企業中間(jian)件”-“分布式(shi)消(xiao)息(xi)服務(wu)”-“Kafka專享版”，進入(ru)分布式(shi)消(xiao)息(xi)服務(wu)Kafka專享版頁面。
步驟(zou) 4 單擊Kafka實例的名(ming)稱(cheng)，進入實例詳(xiang)情頁面。
步驟 5 在左側導航欄選擇(ze)“消費組管理”，進(jin)入消費組列表頁面。
步驟 6 單擊待重置(zhi)消(xiao)費(fei)進度的消(xiao)費(fei)組名稱(cheng)，進入消(xiao)費(fei)組詳(xiang)情頁。
步驟 7 在“消費(fei)進度”頁簽(qian)，通(tong)過以下方法，重置消費(fei)進度。
- 重置單個Topic所有分區的消費進度：在待重置消費進度的Topic后，單擊“重置消費進度”。
- 重置單個Topic中單個分區的消費進度：在待重置消費進度的Topic分區后，單擊“重置消費進度”。
步驟 8 在彈出的“重(zhong)置(zhi)消(xiao)費(fei)進(jin)度(du)”對(dui)話框中，參(can)考(kao)下(xia)表，設置(zhi)重(zhong)置(zhi)消(xiao)費(fei)進(jin)度(du)參(can)數(shu)。
表 重置消費進度參數(shu)說明
參數 說明 重置類型 選擇重置類型：
時間：重置消費進度到指定的時間。
偏移量：重(zhong)置消費進度到指定的偏移量。
一鍵重置(zhi)消費進度只(zhi)支持重置(zhi)消費進度到指定時間。
時間 當“重(zhong)置(zhi)類型”為“時間”時，需(xu)要(yao)設(she)置(zhi)此參數(shu)。
選擇(ze)重置(zhi)消(xiao)費進度的時間點，重置(zhi)完(wan)成后，將從此時間點開始消(xiao)費。
最早：最早偏移量
自(zi)定義：自(zi)定義時間點
最晚：最晚偏移量
偏移量 當“重置類型”為“偏移量”時，需要設置此參數。 選擇重置(zhi)(zhi)消(xiao)費(fei)進度的偏移(yi)量(liang)(liang)，此偏移(yi)量(liang)(liang)不能小于0，重置(zhi)(zhi)完成后(hou)，將(jiang)從此偏移(yi)量(liang)(liang)開始消(xiao)費(fei)。
步驟 9 單擊“確(que)定”，彈出確(que)認(ren)對話框。
步驟 10 單擊“是”，完成消費進度(du)的重置。
