尊敬的 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 为 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 资源

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