亲爱的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 来检查绑定配置中涉及的所有流是否可用。
…