親愛的Spring社群！

我很高興地宣佈兩個適用於Amazon Web Services的 Spring Milestone 版本：Spring Integration for AWS 2.0.0.M1 和 Spring Cloud Stream Binder for AWS Kinesis 1.0.0.M1。

這兩個里程碑版本都可以在 Spring Milestone 倉庫中獲取，並且可以作為 Maven 依賴項使用。

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-aws</artifactId>
    <version>2.0.0.M1</version>
</dependency>

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-kinesis</artifactId>
    <version>1.0.0.M1</version>
</dependency>

Spring Integration for AWS

2.0 版本是 Spring Integration for AWS Framework 的下一代。它基於 Java 8、Spring Framework & Spring Integration 5.0 以及 Spring Cloud for AWS 2.0。在這個新版本中，我們改進了所有的 MessageHandler 實現，使其擴充套件通用的 AbstractAwsMessageHandler，並支援 AsyncHandler、failureChannel 和 ErrorMessageStrategy。添加了一組 AwsHeaders.RECEIVED_ 頭，以避免當請求訊息從上游 AWS Inbound Channel Adapter 到達時，在出站端產生混淆。這在使用需要相同入站和出站繫結的 Spring Cloud Stream “processor-application” 時非常方便。KinesisMessageDrivenChannelAdapter 現在透過 errorChannel 支援錯誤處理，並且一個新的 KinesisMessageHeaderErrorMessageStrategy 在 ErrorMessage 頭中提供了有用的 AwsHeaders.RAW_RECORD 資訊。

Spring Cloud Stream Binder for AWS Kinesis

Spring Cloud Stream Binder for AWS Kinesis 提供了 Spring Cloud Stream 的繫結實現。該實現以 Spring Integration AWS Kinesis Channel Adapters 為基礎。以下說明了 Kinesis Binder 實現如何將每個配置的目的地對映到 AWS Kinesis Streams。

與 Apache Kafka 不同，AWS Kinesis 不提供開箱即用的消費者組支援。此功能的支援是作為 MetadataStore 的一部分實現的。KinesisMessageDrivenChannelAdapter 中分片檢查點的鍵為 [CONSUMER_GROUP]:[STREAM]:[SHARD_ID]。預設情況下，Kinesis Binder 使用 DynamoDbMetaDataStore 實現，該實現也如上所述繼承自 Spring Integration for AWS 專案。

與 RabbitMQ 和 Apache Kafka 類似，可以覆蓋生產者和消費者的繫結配置。它們分別在 KinesisConsumerProperties 和 KinesisProducerProperties 中公開。

非常感謝所有幫助塑造這個專案的 社群成員，他們的寶貴意見和貢獻！

歡迎透過適當的溝通渠道提出任何反饋、功能建議、批評、bug 報告和問題。

Spring Integration AWS 專案頁面 | Spring Cloud Stream Binder for AWS Kinesis 專案頁面 | 幫助 | 聊天