我们能用Spring kafka只处理一次吗？

Question

我正试图让Kafka的消费者消费一次<我的要求是：

1. 从Topic读取数据
2. 处理数据[涉及调用另一个API]
3. 将响应写回Kafka
   我想知道在这种情况下是否可以完全一次？
   我知道用例满足Kafka流API，但我想从生产者/消费者API中知道？此外，如果让我们说在处理数据后，消费者因某种原因失败（处理应该只完成一次），那么处理此类情况的最佳方法是什么？
   此类情况可以有任何延续/检查点吗？
   我知道Kafka Streams API是生产-消费者-生产事务性的。这里还有，如果在调用API消费者崩溃后，流将从一开始就开始，对吗？
   请在这几点上帮忙。
   谢谢。

Answer 1

对Spring for Apache Kafka以与Kafka Streams相同的方式支持一次语义。

看见

https://docs.spring.io/spring-kafka/docs/current/reference/html/#exactly-一次

和

https://docs.spring.io/spring-kafka/docs/current/reference/html/#transactions

记住，“恰好一次”意味着整个过程是成功的

消费-

只执行一次。但是，如果生产步骤失败（回滚事务），则消费-

因此，您需要使进程部分幂等。