今天，我很高兴地宣布 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 客户端 和 Kinesis 生产者 库的新功能。为此，spring-integration-aws 分别附带了 KclMessageDrivenChannelAdapter 和 KplMessageHandler 实现。目前，实现基于 KCL v1.x，因为我们在 spring-integration-aws 中使用的并非所有 AWS 依赖项都提供了 AWS SKD v2 实现。根据 Kinesis 客户端库的调查，已向 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 流，可以将其作为 Kinesis 消费者记录处理。为此，应使用属性配置特定的输入绑定。

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 资源

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