我最近看到 Spring-Kafka 项目已经实现了 OOO 提交来处理 Kafka 消息。我想知道如何在 Reactor-Kafka 中使用或实现此功能。没有这个，它可能会导致我们提交一个之前的消息，它的处理还没有完成。
我们寻求的解决方案是跟踪轮询消息并仅在所有先前消息（在同一分区中）已被确认后才提交消息。
我还看到了一些关于其他框架的主题的讨论。如前所述，它已在 Spring-Kafka 中实现。除此之外，还有一篇很棒的文章解释了 Quarkus 对这个问题的实现。就在这里。这真的会帮助我了解任何解决方案。谢谢