亲爱的 Spring 社区！

我很高兴地宣布支持Amazon Web Services 的 Spring 项目正式发布：Spring Integration for AWS 2.0.0.RELEASE 和 Spring Cloud Stream Binder for AWS Kinesis 1.0.0.RELEASE。

这两个工件都可以在Spring 发布 仓库和 Maven Central 中找到，并可以作为依赖项使用。

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-aws</artifactId>
    <version>2.0.0.RELEASE</version>
</dependency>
...
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-kinesis</artifactId>
    <version>1.0.0.RELEASE</version>
</dependency>

当使用第二个工件时，不需要包含spring-integration-aws。

当然，此 Spring Integration for AWS 2.0 版本的主要目标是围绕 AWS Kinesis 支持，这是由 Spring Cloud Stream Binder for AWS Kinesis 中的工作驱动的。特别是，我们引入了 DynamoDbMetadataStore 和 DynamoDbLockRegistry 来支持 AWS Kinesis 的分布式 Binder 消费者。同时，遵循完善的 Spring Integration 抽象，这些新组件可以用于任何其他分布式任务，当您的应用程序部署到 Amazon 云环境中或依赖于 AWS 服务时。例如，AWS S3 入站通道适配器可以使用 DynamoDbMetadataStore 用于 S3PersistentAcceptOnceFileListFilter 来防止在多个分布式应用程序实例中访问相同的已处理资源。DynamoDbLockRegistry 可用于应用程序集群中的领导者选举。有关 LockRegistryLeaderInitiator 的更多信息，请参阅Spring Integration 参考手册。

除了这些新组件之外，SNS 和 SQS 通道适配器现在还支持将标头映射回消息属性。有关更多详细信息，请参阅 AbstractMessageAttributesHeaderMapper 的 Javadoc 及其实现。

Kinesis 通道适配器也支持标头映射，但机制完全不同，我们只能将它们与有效负载一起嵌入到记录正文中。有关更多详细信息，请参阅 Spring Integration 中的 EmbeddedJsonHeadersMessageMapper。当 headerMode 为 embedded（默认值）时，Kinesis Binder 中也使用了类似的嵌入技术。

有关 Spring Integration for AWS 2.0 中的新功能以及 Spring Cloud Stream Binder for AWS Kinesis 的更多信息，请参阅以前的发布公告。

另请参阅Spring Cloud Stream 示例，以获取有关如何在云流应用程序中使用 Kinesis Binder 的更多想法。

感谢所有以任何方式为这些项目做出贡献的人。

我们期待您的任何反馈，并很高兴在接下来的版本中改进这些项目以满足社区的需求。

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