我們很高興地宣佈 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 與我們聯絡。