升级到 2.1.0 后,Kinesis spring binder 写入 SpringIntegrationLockRegistry 的次数增加了两倍,为什么?

Kinesis spring binder after upgrade to 2.1.0 number of writes to SpringIntegrationLockRegistry tripled, why?

最近将 spring kinesis binder 从 2.0.1.RELEASE 更新到 2.1.0 并开始看到 DynamoDB table 针对 table SpringIntegrationLockRegistry 的写入次数增加了三倍. 想知道是否有人知道现在正在做的这个库中发生了什么变化。

谢谢。

我认为此提交做了相应的更改:https://github.com/spring-projects/spring-integration-aws/commit/ac74dfd2368c5c4b74793c259312313ad21ed5f8

所以,每次我们准备消费的时候,我们都会更新一个锁。如果运行时没有加锁,我们就不是锁持有者,所以不要消费。