领先一步
VMware 提供培训和认证,以加速您的进步。
了解更多我们很高兴地宣布发布 Spring Cloud Stream Horsham (3.0.0.RELEASE) 发布列车,该列车作为 Spring Cloud Hoxton.RELEASE(即将发布)的一部分提供,并基于 Spring Boot 2.2.x 和 Spring Cloud Function 3.0.0.RELEASE,后者也刚刚发布。
Spring Cloud Stream Horsham.RELEASE 模块可在 Maven Central 存储库中使用。
正如这些文章中所述(简化和澄清、函数式和响应式、流和 Spring Integration 以及 事件路由)在本次公告之前,此版本的核心主题是函数!
从历史上看,Spring Cloud Stream 公开了基于注解的配置模型,该模型要求用户了解并提供大量样板信息,而这些信息原本可以很容易地推断出来。您可以阅读更多相关详细信息此处,但在此版本和随后的 Spring Cloud Functions 版本中,情况已不再如此。
流应用程序只是一个引导应用程序!
@SpringBootApplication
public class SampleApplication {
@Bean
public Function<String, String> uppercase() {
return value -> value.toUpperCase();
}
}
是的,以上是完全功能性的 Spring Cloud Stream 应用程序
大多数值得注意的功能和增强功能都强调了我们对函数式编程模型的承诺;
路由函数 - 有效地对应于@StreamListener
注解的condition
属性提供的相同功能(以及更多功能)。有关更多详细信息,请参阅事件路由。
使用函数进行多个绑定(多个消息处理程序) - 有关更多详细信息,请参阅单个应用程序中的多个函数。
函数元数(具有多个输入/输出的函数 - 可以订阅或目标多个目的地的单个函数) - 有关更多详细信息,请参阅具有多个输入和输出参数的函数。
对响应式编程的原生支持 - 从 v3.0.0 开始,我们不再分发 spring-cloud-stream-reactive 模块,而是依赖于 spring cloud function 提供的原生响应式支持。为了向后兼容,您仍然可以从以前的版本中引入 spring-cloud-stream-reactive。
Schema Registry 模块已迁移到独立项目
有关更多信息,您还应该查看更新的用户指南。
Kafka Streams 绑定器现在支持基于函数的一流编程模型,使用该模型,您现在可以基于 java.util.function 支持编写 Kafka Streams 应用程序。这进一步减少了应用程序需要编写的样板代码,并允许开发人员专注于手头的业务逻辑。有关更多详细信息,请访问函数式风格部分以了解更多详细信息。Soby Chako(Spring Cloud Stream Kafka 绑定器的负责人)计划撰写一系列专门的文章,介绍所有新功能。
与往常一样,我们欢迎您的反馈和贡献,因此请在Stackoverflow 或GitHub 或Gitter 上与我们联系。