Spring Cloud Stream 与 Kafka Stream 的 Exactly Once 功能对比

Question

我无法在此处以及 Spring 网站和博客上找到 Spring Cloud Stream 是否能够提供 Kafka Stream API 提供的“Exactly Once”语义。也许没有单个配置/注释，并且在线程“是否可以使用 Spring Cloud Stream 进行一次处理？ ”我可以找到一些有用的东西，但专家的答案是非常高的水平。感谢帮助

Answer 1

Spring Cloud Stream 在处理保证方面没有做任何特别的事情。processing.guarantee您可以通过提供属性并将其设置为 来将其委托给 Kafka Streams exactly-once。请参阅此了解更多详细信息。使用 Spring Cloud Stream Kafka Streams 绑定器时，您可以将其作为属性提供给 Spring Boot 应用程序，如下所示。

spring.cloud.stream.kafka.streams.binder.configuration.processing.guarantee。

请记住，只有当您将结果写回 Kafka 时，Kafka Stream 的恰好一次保证才有效。