反复出现的警告 - 无法清理 KCL 2.3 上的租约

Question

我在我的 kinesis 流中执行了从 1 个分片到 2 个分片的重新分片，之后我的 KCL 使用者每隔一分钟就会记录以下警告。

由于 LeaseCleanupManager.LeaseCleanupResult(cleanedUpCompletedLease=false, cleanUpGarbageLease=false, wereChildShardsPresent=true, wasResourceNotFound=false)，无法清理 newStream 的租约 shardId-000000000006

shardId-000000000006 是被分成两个子分片 7 和 8 的父分片。我的 DynamoDB 条目是这样的：

重新启动消费者没有帮助。这是否值得关注，为什么工人无法清理 shardId-000000000006 上的租约？

Answer 1

这似乎是预期的行为。一旦两个子分片都执行了检查点，shardId-000000000006 租约就被清理干净了。