今天我很高兴地宣布 Spring Integration for Amazon Web Services 扩展版本 2.2.0 和 Spring Cloud Stream Binder for AWS Kinesis 版本 1.2.0 正式发布。

这些版本可以从 Maven Central、JCenter 和我们的 发布仓库 下载

compile "org.springframework.integration:spring-integration-aws:2.2.0.RELEASE"

如果您不使用 Kinesis Binder。或者通过 Binder 依赖

compile "org.springframework.cloud:spring-cloud-stream-binder-kinesis:1.2.0.RELEASE"

这两个版本的主题都是关于支持 Kinesis Client 和 Kinesis Producer 库的新功能。为此，spring-integration-aws 提供了 KclMessageDrivenChannelAdapter 和 KplMessageHandler 实现。目前，该实现基于 KCL v1.x，因为我们在 spring-integration-aws 中使用的并非所有 AWS 依赖项都提供 AWS SKD v2 实现。根据 Kinesis Client Library 的研究，已为 KclMessageDrivenChannelAdapter 和 KinesisMessageDrivenChannelAdapter 引入了额外的 CheckpointMode.periodic。

spring-cloud-stream-binder-kinesis 基于最近发布的 Spring Cloud Stream 版本 2.2，并提供了一个新的 Binder 配置选项来启用 KCL/KPL 功能

spring.cloud.stream.kinesis.binder.kplKclEnabled = true

KCL/KPL 依赖项已显式包含在 spring-cloud-stream-binder-kinesis 中，因此只需简单地决定为 Kinesis Binder 选择经典模式还是 KCL/KPL 模式。

Kinesis Binder 的另一个新功能是 DynamoDB Streams，它可以作为 Kinesis Consumer 记录来处理。为此，应使用属性配置特定的输入绑定

spring.cloud.stream.kinesis.bindings.<channelName>.consumer.dynamoDbStreams = true

如果您的 Spring Cloud Stream 微服务仅在 source 模式下工作，则 DynamoDB 和 Cloud Watch 的配置现在也是可选的。只需担心 Kinesis 生产者配置，无论是经典模式还是 KPL 模式。

非常感谢社区中的每个人对这些项目的所有反馈和贡献。

欢迎通过所有可用的沟通渠道提供任何反馈！

Spring Integration for AWS 资源

项目页面 | 贡献 | 帮助 | 聊天

Spring Cloud Stream Binder for AWS Kinesis 资源

项目页面 | 贡献 | 帮助 | 聊天