模式 描述
MANUAL poll()拉取一批消息,處理完業務后,手動調用Acknowledgment.acknowledge()先將offset存放到map本地緩存,在下一次poll之前從緩存拿出來批量提交
MANUAL_IMMEDIATE 每處理完業務手動調用Acknowledgment.acknowledge()后立即提交
RECORD 當每一條記錄被消費者監聽器(ListenerConsumer)處理之后提交
BATCH 當每一批poll()的數據被消費者監聽器(ListenerConsumer)處理之后提交
TIME 當每一批poll()的數據被消費者監聽器(ListenerConsumer)處理之后,距離上次提交時間大於TIME時提交
COUNT 當每一批poll()的數據被消費者監聽器(ListenerConsumer)處理之后,被處理record數量大於等於COUNT時提交
COUNT_TIME TIME或COUNT滿足其中一個時提交
參考