我们正在为Kafka使用Spring Cloud Stream，我们正在寻找消费者API的精确一次语义

Question

我们正在为Kafka使用Spring Cloud Stream，并寻找精确的一次性语义。我们有一个解决方案，正如预期的那样运行良好1）启用幂等元

但现在我们发现有一个属性（producer.sendfoffsetstotransaction）Kafka API，它可以帮助我们修复消费者端的重复处理，而无需任何元数据存储逻辑。现在，我不确定如何使用具有此属性的spring cloud stream实现这一点。sendOffsetsToTransaction

Answer 1

如果您将KafkaTransactionManager添加到应用程序上下文，它会由框架自动处理。

您必须向配置中添加事务id前缀。

spring.kafka.producer.transaction-id前缀

引导将自动添加事务管理器。

请参见生产者属性。

spring。云流动Kafka。粘合剂交易交易IDPrefix

启用活页夹中的事务。请参阅事务。Kafka文档中的id和SpringKafka文档中的事务。启用事务后，将忽略单个生产者属性，并且所有生产者都使用spring。云流动Kafka。粘合剂交易生产商。*属性。

当侦听器正常退出时，侦听器容器在提交事务之前将偏移量发送到事务。