亲爱的 Spring 社区！

我很高兴地宣布针对Amazon Web Services 的两个 Spring 里程碑版本发布：用于 AWS 的 Spring 集成 2.0.0.M1 和 用于 AWS Kinesis 的 Spring Cloud Stream 绑定器 1.0.0.M1。

这两个里程碑版本都可以在Spring 里程碑 仓库中找到，并且可以作为 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>

用于 AWS 的 Spring 集成

2.0 版本是用于 AWS 框架的 Spring 集成的下一代版本。它基于 Java 8、Spring Framework 和 Spring 集成 5.0 以及 用于 AWS 的 Spring Cloud 2.0。在这个新版本中，我们改进了所有 MessageHandler 实现，以扩展通用的 AbstractAwsMessageHandler，并支持 AsyncHandler、failureChannel 和 ErrorMessageStrategy。添加了一组 AwsHeaders.RECEIVED_ 头，以避免当请求消息从上游 AWS 入站通道适配器到达时，在出站侧出现混淆。当它与需要相同入站和出站绑定的 Spring Cloud Stream “处理器应用程序”一起使用时，这非常方便。KinesisMessageDrivenChannelAdapter 现在支持通过 errorChannel 进行错误处理，并且新的 KinesisMessageHeaderErrorMessageStrategy 在 ErrorMessage 头中提供了有用的 AwsHeaders.RAW_RECORD 信息。

用于 AWS Kinesis 的 Spring Cloud Stream 绑定器

用于 AWS Kinesis 的 Spring Cloud Stream 绑定器为 Spring Cloud Stream 提供绑定实现。此实现在其基础上使用 Spring 集成 AWS Kinesis 通道适配器。以下是 Kinesis 绑定器实现如何将每个配置的目的地映射到 AWS Kinesis 流。

与Apache Kafka 不同，AWS Kinesis 没有提供开箱即用的消费者组支持。此功能的支持作为 MetadataStore 的一部分实现。KinesisMessageDrivenChannelAdapter 中分片检查点的键 - [CONSUMER_GROUP]:[STREAM]:[SHARD_ID]。默认情况下，Kinesis 绑定器使用 DynamoDbMetaDataStore 实现，这也如上所述继承自用于 AWS 的 Spring 集成项目。

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

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

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

Spring 集成 AWS 项目页面 | 用于 AWS Kinesis 的 Spring Cloud Stream 绑定器项目页面 | 帮助 | 聊天