本文為您介紹Consumer在讀取訊息異常中斷後,如何在控制台管理Consumer的offset。
消費位點的提交機制
消費訊息並不保證會提交消費位點,Broker記錄的是用戶端提交的消費位點。
提交消費位點的機製取決於您使用的用戶端SDK,一般支援以下兩種機制:
自動認可:按照時間間隔,SDK把消費過的最新訊息的位點+1提交上去。
手動提交:在應用程式裡,把消費過的最新訊息的位點+1提交上去。
本文為您介紹Consumer在讀取訊息異常中斷後,如何在控制台管理Consumer的offset。
消費訊息並不保證會提交消費位點,Broker記錄的是用戶端提交的消費位點。
提交消費位點的機製取決於您使用的用戶端SDK,一般支援以下兩種機制:
自動認可:按照時間間隔,SDK把消費過的最新訊息的位點+1提交上去。
手動提交:在應用程式裡,把消費過的最新訊息的位點+1提交上去。