尊敬的 Spring 社区！

我很高兴地宣布为 Amazon Web Services 发布两个 Spring 里程碑版本：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“处理器应用程序”时非常方便，因为它需要相同的入站和出站绑定。 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 中 shard 检查点的键 - [CONSUMER_GROUP]:[STREAM]:[SHARD_ID]。 默认情况下，Kinesis Binder 使用 DynamoDbMetaDataStore 实现，该实现也继承自上述 Spring Integration for AWS 项目。

与 RabbitMQ 和 Apache Kafka 类似，可以覆盖生产者和消费者的绑定配置。 它们分别在 KinesisConsumerProperties 和 KinesisProducerProperties 中公开。

非常感谢所有 社区成员，他们通过宝贵的意见和贡献帮助塑造了这个项目！

欢迎通过适当的沟通渠道提供任何反馈、功能建议、批评、错误报告和问题。

Spring Integration AWS 项目页面 | Spring Cloud Stream Binder for AWS Kinesis 项目页面 | 帮助 | 聊天