全部產品
Search
文件中心

ApsaraMQ for Kafka:如何在控制台管理Consumer的offset?

更新時間:Dec 27, 2024

本文為您介紹Consumer在讀取訊息異常中斷後,如何在控制台管理Consumer的offset。

消費位點的提交機制

消費訊息並不保證會提交消費位點,Broker記錄的是用戶端提交的消費位點。

提交消費位點的機製取決於您使用的用戶端SDK,一般支援以下兩種機制:

  • 自動認可:按照時間間隔,SDK把消費過的最新訊息的位點+1提交上去。

  • 手動提交:在應用程式裡,把消費過的最新訊息的位點+1提交上去。

操作步驟

  1. 查看消費位點

    Topic 详情頁面的订阅关系頁簽,單擊目標Topic操作列的消费详情,查看Consumer提交的消费位点。Consumer消費時,從這個位點繼續消費。具體操作,請參見查看消費狀態

  2. 重設消費位點

    Group 詳情頁面,單擊重置消费位点,在重設Group的消費位點面板,設定重設策略進行重設消費位點。具體操作,請參見重設消費位點

    重要

    在控制台上重設消費位點時,需要先停止消費用戶端。否則,重設的結果很可能被消費端覆蓋。