日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

重置消費位點

重置消費位點是指改變訂閱者當前的消費位置。當消費者出現故障或者消費錯誤數據時,您可通過重置消費位點將消費位置回滾到之前的某個位點或者指定分區位點,重新開始消費。您也可以將消費位置移動至最新位點,暫時不處理堆積的消息。

前提條件

已停止所有Consumer客戶端(云消息隊列 Kafka 版不支持在線重置消費位點)。

重要

在停止Consumer客戶端后,需要經過ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的時間(默認10000 ms),服務端才認為Consumer真正下線。

背景信息

云消息隊列 Kafka 版支持以下重置消費位點方式:

  • 從最新位點開始消費:不再消費Broker上堆積的消息,將消費位點重置到最新的位置。

    說明

    堆積的消息本身并不會因此被刪除,改變的只是消費位點。

  • 指定時間點開始消費:將消費位點重置到過去的某個時間點(該時間點以Topic的消息存儲時間為準)。

  • 按分區消費位點進行重置:如果只有少量分區產生消息堆積,可以僅重置指定分區的消費位點,避免重復消費其他分區中已正確處理的消息。

操作步驟

  1. 登錄云消息隊列 Kafka 版控制臺

  2. 概覽頁面的資源分布區域,選擇地域。

  3. 實例列表頁面,單擊目標實例名稱。

  4. 在左側導航欄,單擊Group 管理

  5. Group 管理頁面,找到目標Group,在其右側操作列,選擇更多 > 重置消費位點

  6. 重置Group的消費位點面板,了解其前提條件,設置重置策略。

    1. 設置重置所有 Topic

      • 單擊,重置所有Topic的消費位點。

      • 單擊,在Topic文本框輸入需要重置Topic的名稱。

    2. 設置重置方式

      • 單擊從最新位點開始消費,將消費位點指定到最新的位置,單擊確定

      • 單擊從指定時間點的位點開始消費,在時間點文本框,單擊日歷,從指定時間點的位點開啟消費功能,單擊確定

      • 單擊按分區消費位點進行重置,在目標分區所在行, 消費位點文本框輸入開始消費位點值,單擊確定

  7. 提示對話框,確認提示信息,單擊確認

相關文檔