亲爱的 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 框架进行集成测试，这帮助我们发现了这两个库中的几个错误和竞争条件。

• spring-integration-aws 提供了 PutRecordsRequest（批处理）支持 KplMessageHandler，使用 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 资源

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