我们很高兴地宣布 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 绑定执行器端点之外，还添加了对 output 绑定执行器端点的支持。

Rabbit Binder

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

Kafka Binder

• 现在在绑定程序中的 Kafka 主题名称中支持通配符 [kafka 绑定程序]
• 新的注解 KafkaStreamsStateStore 用于在 Kafka Streams 中的低级处理器 API 中创建状态存储 [kafka streams 绑定程序]
• 删除 Kafka Streams 绑定程序中不必要的重新分区主题的创建
• 在 Kafka Streams 绑定程序中从多个主题消费
• 改进了 Kafka Streams 绑定程序中的交互式查询支持 - 现在支持多个消费者和跨它们进行查询。
• 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 与我们联系。