kafka中ackMode各個參數的含義


模式                   描述
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滿足其中一個時提交

參考

https://blog.csdn.net/huangdi1309/article/details/119056772

https://blog.csdn.net/yinni11/article/details/85129933?utm_medium=distribute.pc_relevant.none-task-blog-2~default~baidujs_title~default-0.no_search_link&spm=1001.2101.3001.4242.1


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM