是否可以使用 Spring Cloud Stream 进行一次处理？

【问题标题】：Is it possible to get exactly once processing with Spring Cloud Stream?是否可以使用 Spring Cloud Stream 进行一次处理？
【发布时间】：2019-06-10 05:37:01
【问题描述】：

目前我正在使用具有几乎默认配置的 SCS 在微服务之间发送和接收消息。不知怎的，我读到了这篇
https://www.confluent.io/blog/enabling-exactly-kafka-streams

想知道如果我们只是通过 Spring Boot 应用程序中的属性将名为“processing.guarantee”的属性设置为“exactly-once”，它是否会起作用？

【问题讨论】：

标签： spring-boot apache-kafka-streams spring-cloud-stream spring-kafka

【解决方案1】：

在您的问题的上下文中，您应该将 Spring Cloud Stream 视为目标系统（例如 Kafka）和您的代码之间的代理。启用这种委托的绑定器通常以传播目标系统支持的任何功能的方式实现。

【讨论】：

@ekbunditw 很抱歉对此发表评论有点晚，但只是为了补充 Oleg 所说的，Spring Cloud Stream 并没有做任何特别的事情来实现一次交付保证，但是，您可以使用您的属性提到实现它，因为本例中的目标平台（Apache Kafka）支持它。