Spring Integration for AWS 2.0 GA 和 Spring Cloud Stream Kinesis Binder 1.0 GA

发布 | Artem Bilan | 2018 年 8 月 21 日 | ...

亲爱的 Spring 社区!

我很高兴宣布全面推出支持 Amazon Web Services 的 Spring 项目:Spring Integration for AWS 2.0.0.RELEASESpring Cloud Stream Binder for AWS Kinesis 1.0.0.RELEASE

这两个工件都可以在 Spring Release 仓库和 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 中所做的工作。 特别是,我们引入了 DynamoDbMetadataStoreDynamoDbLockRegistry 来支持 AWS Kinesis 的分布式 Binder 使用者。 同时,遵循格式良好的 Spring Integration 抽象,当您的应用程序部署到 Amazon 云环境或当您依赖 AWS 服务时,这些新组件可以用于任何其他分布式任务。 例如,AWS S3 入站通道适配器可以使用 DynamoDbMetadataStore 用于 S3PersistentAcceptOnceFileListFilter,以防止访问多个分布式应用程序实例中已处理的相同资源。 DynamoDbLockRegistry 可用于应用程序集群中的领导者选举。 有关 LockRegistryLeaderInitiator 的更多信息,请参阅 Spring Integration 参考手册

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

Kinesis 通道适配器也支持标头映射,但该机制完全不同,我们只能将它们与有效负载嵌入到记录正文中。 有关更多详细信息,请参阅 Spring Integration 中的 EmbeddedJsonHeadersMessageMapper。 当 headerModeembedded(默认值)时,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 项目页面 | 帮助 | 聊天

获取 Spring 新闻通讯

与 Spring 新闻通讯保持联系

订阅

抢占先机

VMware 提供培训和认证,以加速您的进步。

了解更多

获得支持

Tanzu Spring 在一个简单的订阅中提供对 OpenJDK™、Spring 和 Apache Tomcat® 的支持和二进制文件。

了解更多

即将举行的活动

查看 Spring 社区中所有即将举行的活动。

查看全部