今天，我很高兴地宣布 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 消费者记录进行处理。为此，需要使用以下属性配置特定的输入绑定：

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

此外，如果您的 Spring Cloud Stream 微服务仅以 source 模式工作，则 DynamoDB 和 Cloud Watch 的配置现在是可选的。您只需要关心 Kinesis producer 的配置，无论是经典模式还是 KPL 模式。

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

任何反馈都可以通过所有可用的沟通渠道提出！

Spring Integration for AWS 资源

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

Spring Cloud Stream Binder for AWS Kinesis 资源

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