Reactor Kafka receiveAutoAck 和至少一次语义

Question

在Reactor Kafka中，当使用

receiveAutoAck

时，如果框架在用户代码处理并返回事件后确认事件，这不是尊重“至少一次”语义吗？或者确认是否在将一批事件传递给用户代码之前发生？

Answer 1

其通常的工作原理如下：

1. Reactor Kafka 消费来自 Kafka 的一批消息。
2. 它将这个批次传递给用户代码进行处理。
3. 一旦用户代码处理完消息而没有抛出错误，Reactor Kafka 就会自动向 Kafka 确认消息。
4. 如果处理过程中出现错误，消息将不会被确认，并且会被重新发送给消费者进行再次处理。