亲爱的Spring社区，

今天，我很高兴地宣布 Spring Integration for Amazon Web Services 扩展版本 2.3.0 和 Spring Cloud Stream Binder for AWS Kinesis 版本 2.0.0 正式可用。

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

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

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

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

发布亮点

• 这两个版本的主要主题是使用 Local Stack 框架进行集成测试，这帮助我们发现了这两个库中的几个 bug 和竞态条件。

• spring-integration-aws 为 KplMessageHandler 提供了 PutRecordsRequest (批处理) 支持，使用 Project Reactor 的 Mono.fromFuture() 功能来收集该批处理中 UserRecords 的异步结果。

• 当下一个分片请求返回 null 时，KinesisMessageDrivenChannelAdapter 将发出 KinesisShardEndedEvent，表示分片已关闭，不能再向其中添加任何记录。

• spring-cloud-stream-binder-kinesis 基于最近发布的 Spring Cloud Stream 版本 3.0，并提供了一个新的 KinesisBinderHealthIndicator 来检查绑定配置中涉及的所有流是否可用。

• 现在可以在应用程序上下文中将 ProducerMessageHandlerCustomizer 和 ConsumerEndpointCustomizer 指定为 bean，它们将被注入到 KinesisMessageChannelBinder 中以进行适当的端点自定义。例如，当某些端点属性未被配置选项覆盖时，这会很有用。

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

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

Spring Integration for AWS 资源

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

Spring Cloud Stream Binder for AWS Kinesis 资源

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