Shard [shardId-000000000000]未关闭。如果我们在执行reshard操作时构造了碎片列表，就会发生这种情况。

Question

我是在从亚马逊动态流中获取数据时得到这个错误的。我正在做下面的步骤

1. 创造亚马逊动力蒸汽
2. 数据使用putRecord api的AmazonKinesisClient。
3. 然后使用KCL库的工作人员从流中获取数据。

Answer 1

有几种可能性。

1. 在命令创建流之后，是否需要等待足够长的时间才能完成？有时，创建一个碎片可能需要10分钟。由于您成功地使用了putRecord方法，所以流和碎片应该是活动的。
2. 您正确配置了DynamoDB吗？我假设您正在使用它来实现Kinesis同步。查看DynamoDB表中的记录。全是列.leaseKey、检查点、leaseOwner、parentShardId等)填好了吗？也许数据库中的数据是旧的，所以您可能正在访问一个封闭的碎片？

您提到的例外是：https://github.com/awslabs/amazon-kinesis-client/blob/master/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncer.java#L193

尝试删除DynamoDB表，让(KCL)创建一个全新的表。链接：https://console.aws.amazon.com/dynamodb/