我们很高兴地宣布 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 的实现来支持 Message Listener 容器定制。
• 支持绑定属性优先级。此功能允许使用特定的绑定属性覆盖默认的绑定属性。例如。

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 绑定器] 中，现在支持 kafka 主题名称中的通配符
• 用于在 kafka streams 的较低级别处理器 API 中创建 state stores 的新注解 KafkaStreamsStateStore [kafka streams 绑定器]
• 移除 kafka streams 绑定器中不必要的 repartition topic 的创建
• 在 kafka streams 绑定器中从多个 topic 进行消费
• kafka streams 绑定器中的交互式查询支持改进 - 现在支持多个消费者以及跨它们进行查询。
• QueryableStoreRegistry 已被弃用，并提供了一个名为 InteractiveQueryService 的新 API。除了提供查询 state stores 的能力外，此 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 计划在七月底发布，将主要包含新的绑定功能以及与 Spring Cloud Function 的集成

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