我们很高兴地宣布 Spring Cloud Stream Fishtown 发布系列的第一个里程碑版本 - Fishtown.M1/2.1.0.M1。

Spring Cloud Stream Fishtown 2.1.0.M1 可在 Spring Milestone 仓库中使用。 发行说明包括有关与 Spring Boot、Spring Cloud、Spring AMQP 和 Spring for Apache Kafka 的版本兼容性的相关信息。

以下部分简要概述了此版本中包含的功能和改进。

显著特性、改进和增强

核心

• 通过简单地注册 ListenerContainerCustomizer bean 的实现，支持消息侦听器容器自定义。
• 绑定属性优先级支持。此功能允许使用特定绑定属性覆盖默认绑定属性。例如。

spring.cloud.stream.default.contentType=text/plain
spring.cloud.stream.default.producer.partitionCount=1
spring.cloud.stream.bindings.output.producer.partitionCount=4

在上面，所有绑定的默认内容类型都设置为 text/plain。 此外，所有生产者绑定的 partitionCount 都设置为 1，但 *output* 目标绑定除外，它设置为 4

• 除了现有的 *input* 绑定 actuator 端点之外，还添加了对 *output* 绑定 actuator 端点的支持。

Rabbit Binder

• 公开了用于设置队列长度和溢出策略的支持
• 多路复用支持

Kafka Binder

• 现在在 binder [kafka binder] 中的 kafka 主题名称中支持通配符。
• 新的注解 KafkaStreamsStateStore 用于在 kafka streams [kafka streams binder] 中的较低层处理器 API 中创建状态存储。
• 删除在 kafka streams binder 中创建不必要的重新分区主题
• 在 kafka streams binder 中从多个主题消费
• 改进了 kafka streams binder 中的交互式查询支持 - 现在支持多个消费者以及跨消费者查询。
• QueryableStoreRegistry 已被弃用，并提供了一个名为 InteractiveQueryService 的新 API。 除了提供查询状态存储的能力之外，此 API 还提供有关消费者运行的主机的信息。
• 多路复用支持

各种其他增强功能和错误 修复

再次感谢所有社区贡献者！！！

注意

如果应用程序是从 Spring Initializr 创建的，则它们需要在 spring-cloud BOM 声明之前的 maven 依赖管理中添加此 BOM 片段

<dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-stream-dependencies</artifactId>
           <version>Fishtown.M1</version>
           <type>pom</type>
           <scope>import</scope>
</dependency>

下一步

M2 计划于 7 月底发布，主要包含新的绑定功能以及与 Spring Cloud Function 的集成

与往常一样，我们欢迎反馈和贡献，因此请通过 Stackoverflow 或 GitHub 或通过 Gitter 与我们联系。