首页 笔记 图片 查字 
所属分类:Kafka
浏览:72
内容:

消费者事务的两个问题
重复消费:自动提交offset引起的,消费者挂了以后,当前offset值还未提交,再次重启后从最后提交的offset开始消费,不是最后的offset。
漏消费:手动提交offset引起的,消费者挂了以后,数据还没有落盘,但是offset已经提交。

想要精确一次性消费,需要下游消费者必须支持事务才可以,如mysql等。