Spring Cloud Stream 具有 Project Reactor 稳定性
Spring Cloud Stream with Project Reactor Stability
我想使用 Spring Cloud Stream 来消费和处理 Apache Kafka 队列并将它们写入 MongoDB。我看到有一个使用库的选项，这样函数将是反应式的或命令式的。在大多数 Spring 项目中，命令式方式是默认方式，但据我了解，在 spring 云流中，反应式范式是默认方式。
我想知道什么被认为是最“稳定”的 api 例如建议企业使用什么？
Reactive API 是稳定的，是的，我们为其提供支持。换句话说，您可以使用响应式 API（例如 Function<Flux, Flux>）编写函数。
但是，我想非常清楚，支持 API 并不意味着支持完整的响应式功能堆栈，因为它们实际上依赖于非响应式的源和目标。
也就是说，使用 Kafka，您可以依赖 Kafka 本身提供的本机反应支持，Spring Cloud Stream 使用 Kafka Streams binder - https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.5/reference/html/spring-cloud-stream-binder-kafka.html#_kafka_streams_binder
我想使用 Spring Cloud Stream 来消费和处理 Apache Kafka 队列并将它们写入 MongoDB。我看到有一个使用库的选项，这样函数将是反应式的或命令式的。在大多数 Spring 项目中，命令式方式是默认方式，但据我了解，在 spring 云流中，反应式范式是默认方式。
我想知道什么被认为是最“稳定”的 api 例如建议企业使用什么？
Reactive API 是稳定的，是的，我们为其提供支持。换句话说，您可以使用响应式 API（例如 Function<Flux, Flux>）编写函数。
但是，我想非常清楚，支持 API 并不意味着支持完整的响应式功能堆栈，因为它们实际上依赖于非响应式的源和目标。
也就是说，使用 Kafka，您可以依赖 Kafka 本身提供的本机反应支持，Spring Cloud Stream 使用 Kafka Streams binder - https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.5/reference/html/spring-cloud-stream-binder-kafka.html#_kafka_streams_binder