SpringKafka消费者确认模式

Question

我需要使用consume process Product模式来处理Kafka消息，并已使用Kafka事务管理器配置了Spring Kafka侦听器容器，还设置了事务id前缀以启用Kafka事务。我正在使用批处理的ack模式，并试图了解在这种模式下，在事务中何时提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack模式批提交偏移量——在事务上下文中也是这样吗，即每个轮询1个事务？

或者，在使用Kafka事务（每个侦听器调用一个事务）时，是否忽略了ack模式批处理？如果是这样的话，鉴于消费者每次读取一条记录都需要与经纪人交谈，它会对消费者的表现产生怎样的负面影响？这是否也意味着我的响应生产者不能再缓冲记录，并将它们批量发送给代理，从而失去生产者异步性？

很抱歉在同一篇文章中问了多个问题（可能太多了）。

Answer 1

使用事务时根本不使用AckMode。记录的偏移量在侦听器退出时和事务提交之前发送。

通过使用批处理侦听器，您可以在列表中获取所有记录，从而改善情况

然而，为了正确地支持生产者保护，您还应该将subBatchPerPartition（在2.3.2中添加）设置为true，这样我们就可以为poll（）返回的每个主题/分区获得一个事务。

同样，子批处理的偏移量将在侦听器退出时发送。

如果您不关心击剑，您可以在一次交易中处理整个批次。