如果springcloudstream能够提供kafka流api提供的“精确一次”语义，我在这里和spring网站和博客上都找不到。也许没有一个单独的配置/注解，在“是否有可能使用spring cloud stream进行一次精确的处理”的线程中，我可以找到一些有用的东西，但是Maven给出的答案非常高。谢谢你的帮助
oiopk7p51#
springcloudstream在处理保证方面没有做任何特别的事情。您可以通过提供 processing.guarantee 属性并将其设置为 exactly-once . 请参阅此以了解更多详细信息。当使用springcloudstreamkafkastreams绑定器时，可以将其作为属性提供给spring引导应用程序，如下所示。 spring.cloud.stream.kafka.streams.binder.configuration.processing.guarantee .请记住，只有在您将结果写回kafka时，kafka流的“一次一次”保证才有效。
processing.guarantee
exactly-once
spring.cloud.stream.kafka.streams.binder.configuration.processing.guarantee
1条答案
按热度按时间oiopk7p51#
springcloudstream在处理保证方面没有做任何特别的事情。您可以通过提供
processing.guarantee属性并将其设置为exactly-once. 请参阅此以了解更多详细信息。当使用springcloudstreamkafkastreams绑定器时，可以将其作为属性提供给spring引导应用程序，如下所示。spring.cloud.stream.kafka.streams.binder.configuration.processing.guarantee.请记住，只有在您将结果写回kafka时，kafka流的“一次一次”保证才有效。