手動提交偏移量

通常，當使用 AckMode.MANUAL 或 AckMode.MANUAL_IMMEDIATE 時，確認必須按順序進行，因為 Kafka 不為每條記錄維護狀態，只為每個組/分割槽維護一個已提交的偏移量。從 2.8 版本開始，您現在可以設定容器屬性 asyncAcks，它允許按任意順序確認輪詢返回的記錄。偵聽器容器將推遲亂序提交，直到收到缺少的確認。消費者將暫停（不傳送新記錄），直到前一次輪詢的所有偏移量都已提交。