操作場景
說明消息刪(shan)除(chu)后(hou)無(wu)法(fa)恢復,請謹慎(shen)操(cao)作(zuo)。
前提條件
刪除消息前,請先在客戶端中設(she)置“auto.offset.reset”參數(shu)。“auto.offset.reset”用來(lai)指定當(dang)Kafka中沒有初始偏(pian)移(yi)量或者當(dang)前偏(pian)移(yi)量不存(cun)在(例(li)如(ru)(ru)當(dang)前偏(pian)移(yi)量已(yi)被刪除)時,消費(fei)者的(de)消費(fei)策略(lve)。取值(zhi)如(ru)(ru)下(xia):
- latest:偏移量自動被重置到最晚偏移量。
- earliest:偏移量自動被重置到最早偏移量。
- none:向消費者拋出異常。
操作步驟
-
登錄管理控制臺。
-
在管理控制臺右上角單擊
,選擇區域。說明請選擇Kafka實例所在的區(qu)域。
-
在管理控制臺左上角單擊
,選(xuan)擇“企業中間件”-“分(fen)布(bu)(bu)式(shi)消(xiao)(xiao)息(xi)服務(wu)”-“Kafka專(zhuan)享版”,進入分(fen)布(bu)(bu)式(shi)消(xiao)(xiao)息(xi)服務(wu)Kafka專(zhuan)享版頁面。 -
單擊Kafka實例名稱,進入實例詳情(qing)頁面。
-
在左側(ce)導(dao)航(hang)欄選擇“Topic管理(li)”,進入Topic列表頁(ye)面。
-
在(zai)待刪(shan)(shan)除(chu)消息(xi)的Topic所(suo)在(zai)行(xing),單擊“消息(xi)刪(shan)(shan)除(chu)”,彈出“消息(xi)刪(shan)(shan)除(chu)”對話(hua)框(kuang)。
-
設置消息刪除參(can)數(shu),如下表所示。
圖消息刪除

表 消息刪除參數說(shuo)明
參數 說明 分區 選擇消(xiao)息所在(zai)的(de)分區編號。 偏移量 輸入偏移量,此偏移量之前的(de)數據將被刪除(chu)。
說明如果“偏移量”設置為(wei)“-1”,表示刪除分區(qu)中所有的消(xiao)息(xi)。
如(ru)果您(nin)輸入的偏(pian)移(yi)量不(bu)在指定分(fen)區(qu)的最早偏(pian)移(yi)量和最晚偏(pian)移(yi)量之間,消息將不(bu)會(hui)被(bei)刪除。
如果需要刪除(chu)多個(ge)分(fen)(fen)區(qu)的消息,單擊“添加分(fen)(fen)區(qu)”,設置(zhi)需要刪除(chu)消息的分(fen)(fen)區(qu)和偏移(yi)量。每(mei)次(ci)最(zui)多可選(xuan)擇10個(ge)分(fen)(fen)區(qu)。
-
單(dan)擊“確定”,彈(dan)出“清理結果”對(dui)話(hua)框,單(dan)擊“確定”,完成消息的刪(shan)除(chu)。
圖 清理結果

,選(xuan)擇“企業中間件”-“分(fen)布(bu)(bu)式(shi)消(xiao)(xiao)息(xi)服務(wu)”-“Kafka專(zhuan)享版”,進入分(fen)布(bu)(bu)式(shi)消(xiao)(xiao)息(xi)服務(wu)Kafka專(zhuan)享版頁面。
