20220423151306.png

基本概念

重复消费：已经消费了数据，但是offset没提交。

漏消费：先提交offset后消费，有可能会造成数据的漏消费。

重复消费

20220423152023.png

漏消费

20220423152239.png

消费者事务

如果想完成Consumer端的精准一次性消费，那么需要==Kafka消费端将消费过程和提交offset过程做原子绑定==。此时我们需要将Kafka的offset保存到支持事务的自定义介质（比如MySQL）。这部分知识会在后续项目部分涉及。

20220423152416.png

如果下游不支持事务，那就无法进行原子绑定和回滚操作。