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