领先一步
VMware 提供培训和认证,助您加速进步。
了解更多亲爱的Spring社区!
我很荣幸地宣布支持 Amazon Web Services 的 Spring 项目的首个 Release Candidates:Amazon Web Services:Spring Integration for AWS 2.0.0.RC1 和 Spring Cloud Stream Binder for AWS Kinesis 1.0.0.RC1。
这两个构件都可以在 Spring Milestone 仓库中找到,并且可以作为 maven 依赖来使用。
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-aws</artifactId>
<version>2.0.0.RC1</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kinesis</artifactId>
<version>1.0.0.RC1</version>
</dependency>
当第二个(Spring Cloud Stream Binder for AWS Kinesis)在使用时,第一个(Spring Integration for AWS)则不需要被包含。AWS Kinesis Binder 也传递性地包含了 AWS Kinesis 和 AWS DynamoDB 的 Java SDK 依赖。现在还包含了 AWS DynamoDB Lock Client 用于领导者选举。
非常感谢社区的贡献和任何反馈,尤其是在真实项目中测试这些产品的帮助。
以下是自上次宣布的 Milestone 2 以来的变更:
添加了一个 DynamoDbLockRegistry 实现,用于基于 AWS DynamoDB Lock Client 基础的分布式锁定。
现在可以为 KinesisMessageDrivenChannelAdapter 提供一个 LockRegistry 和分片(shard)的独占访问权限,然后再进行消费。这样可以确保在一个消费者组中,只有一个消费者读取它感兴趣的分片中的记录。当一个消费者退出(放弃领导权)时,其他消费者可以获取该分片的锁,并从存储的检查点继续消费。
Spring Integration AWS 项目的各个组件中还有一些其他的错误修复和改进。
Kinesis Binder 现在公开了底层 DynamoDbLockRegistry 的配置属性,该注册表用于 Binder 消费者。
Kinesis Binder 项目也进行了一些其他修复。
一如既往,欢迎通过合适的沟通渠道提供任何反馈、功能想法、批评、错误报告和问题!
我们目标是在一周左右发布 GA 版本。
Spring Integration AWS 项目页面 | Spring Cloud Stream Binder for AWS Kinesis 项目页面 | 帮助 | 聊天