我想使用Spring Cloud Stream来消费和处理Apache Kafka队列,并将它们写入MongoDB。我看到有一个选项可以使用这个库,这样函数将是反应性的,或者是命令性的。在大多数Spring项目中,命令式方式是默认的,但据我所知,在spring cloud stream中,反应式范例是默认的。
我想知道什么被认为是最“稳定”的api,例如,对于企业推荐使用什么?
发布于 2021-11-16 09:10:04
Reactive API是稳定的,是的,我们为它提供支持。换句话说,您可以使用反应式应用编程接口(例如,Function<Flux, Flux>)来编写函数。然而,我想非常清楚的是,对API的支持并不意味着对全堆栈反应式功能的支持,因为这些功能实际上依赖于非反应式的源和目标。
也就是说,使用Kafka,您可以依赖Kafka本身提供的本地反应式支持,以及使用Kafka Streams绑定器- 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
https://stackoverflow.com/questions/69982282
复制相似问题