精确一次语义

您可以为监听器容器提供一个 KafkaAwareTransactionManager 实例。当这样配置时，容器会在调用监听器之前启动一个事务。监听器执行的任何 KafkaTemplate 操作都将参与事务。如果监听器成功处理了记录（或使用 BatchMessageListener 时处理多个记录），则容器会使用 producer.sendOffsetsToTransaction() 将偏移量发送到事务，然后事务管理器提交事务。如果监听器抛出异常，则事务将回滚，并且消费者将重新定位，以便在下次轮询时检索回滚的记录。有关更多信息以及如何处理重复失败的记录，请参阅 回滚后处理器。

使用事务可以实现精确一次语义 (EOS)。

这意味着对于一个 read → process → write 序列，保证该序列只执行一次。（读取和处理至少执行一次）。

Spring for Apache Kafka 3.0 及更高版本仅支持 EOSMode.V2

使用 V2 模式，不需要为每个 group.id/topic/partition 创建一个生产者，因为消费者元数据会与偏移量一起发送到事务，代理可以使用这些信息来确定生产者是否被围栏。

有关更多信息，请参阅 KIP-447。

V2 之前是 BETA 版本；EOSMode 已更改以与 KIP-732 框架保持一致。