我很高興代表團隊宣布發布 Spring Cloud Stream 1.0.0.M4。 新版本帶來了一些重大的變更和增強功能，並定義了我們認為對於開發分散式即時資料處理應用程式至關重要的核心抽象和基本元素。 舉例來說，

預設發布/訂閱語意

Spring Cloud Stream 1.0.0.M4 中最重要的變更是應用程式彼此互動的方式。 我們選擇了預設的發布/訂閱模型，其中每個從給定目的地接收訊息的應用程式都會收到訊息的副本。 這更適合串流應用程式的處理模型，其中中間主題充當各種相交資料串流的資料中心，也使點擊等場景更容易、更有效率。 此功能與下一個功能息息相關，即消費者群組。

用於負載平衡和分割的消費者群組

當然，如果給定應用程式有多個實例，我們希望它們充當競爭或分割的消費者 - 訊息應僅傳送到平行運行的實例之一。 現在可以在 Spring Cloud Stream 1.0.0.M4 中使用消費者群組來完成。 輸入繫結可以在執行階段指定消費者群組，例如spring.cloud.stream.bindings.input.group=myGroup。 如果多個應用程式這樣做，它們將成為同一群組的一部分，並且訊息將透過負載平衡或分割策略（由不同的配置集控制）在它們之間分配。 此概念的靈感來自 Kafka，但不同的繫結器實作具有不同的方法來提供此功能，並且這是框架中的一流概念。

繫結器 SPI 簡化

雖然未向一般使用者公開，但繫結器 SPI 是 Spring Cloud Stream 的重要組成部分，並確保框架保持彈性和可擴展性。 在此版本中，我們採取了激進的簡化 SPI 的步驟，使開發人員可以更輕鬆地創建自己的實作（如果需要），除了已經提供的 Kafka、Rabbit 和 Redis。（作為一個公平的警告，我們計劃在 RC 版本之前對繫結器 SPI 進行一些更改）。

Kafka 繫結器偏移重置和啟動偏移控制

Kafka 繫結器現在支援透過 spring.cloud.stream.binder.kafka.resetOffsets 屬性在啟動時重置偏移，允許應用程式透過 spring.cloud.stream.binder.kafka.startOffset 屬性恢復從其訂閱的分區的開頭或結尾進行消費，該屬性可以設定為 earliest 或 latest 偏移。 後者可用於控制新啟動的應用程式的起始偏移。

健康指標支援

Spring Cloud Stream 現在利用 Spring Boot 的應用程式健康管理支援，透過公開繫結器的健康指標，反映中介軟體連線的狀態。 目前 Rabbit 和 Redis 支援此功能，如果繫結器使用與 Boot 提供的預設連線不同的連線，則此功能尤其重要。

可以在GitHub中查看增強功能和修復的完整列表。

Spring Cloud Stream 是 Spring Cloud Data Flow 以及 Spring Cloud Task 的核心組件，並為 Spring Cloud Bus 奠定了基礎。

而且，與往常一樣，我們歡迎提供回饋：無論是在 GitHub 上、在 Stack Overflow 上，還是在 Twitter 上。