是否可以使用 Spring Cloud Stream 进行一次处理? [英] Is it possible to get exactly once processing with Spring Cloud Stream?

问题描述

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

Currently I'm using SCS with almost default configuration for sending and receiving message between microservices. Somehow I've read this
https://www.confluent.io/blog/enabling-exactly-kafka-streams

并想知道如果我们只是通过 Spring Boot 应用程序中的属性将名为processing.guarantee"且值为exactly-once"的属性放在那里，它会起作用吗?

and wonder that it is gonna works or not if we just put the property called "processing.guarantee" with value "exactly-once" there through properties in Spring boot application ?

推荐答案

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

In the context of your question you should look at Spring Cloud Stream as just a delegate between target system (e.g., Kafka) and your code. The binders that enable such delegation are usually implemented in such way that they propagate whatever functionality supported by the target system.

这篇关于是否可以使用 Spring Cloud Stream 进行一次处理?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！