AWS Kinesis - 账户 XXX 下的流 XXX 中的分片 XXX 上的 GetShardIterator 无效，因为它不是来自此流

Question

所以这是我的问题。

是否启用了 DynamoDB

Amazon Kinesis Data Streams for DynamoDB

并为其创建了

Amazon Kinesis

数据流。

使用 Kinesis 数据流作为源、Redshift 作为目标创建 ETL 作业，并在两者之间进行一些转换。

由于某些原因，我删除了

Amazon Kinesis

流向的

Amazon Kinesis Data Streams for DynamoDB

数据流，并创建了一个具有完全相同名称的新数据流。

现在 ETL 作业返回了

GetShardIterator on shard shardId-000000000001 in stream my-stream-name under account XXXXXXXXXXXX is invalid because it did not come from this stream.

如何在不删除主 DynamoDB 表的情况下修复此问题？

Answer 1

您的消费者仍在尝试从原始流中读取数据，该流具有唯一的分片 ID。确保重置消费者以收听新的流，如果更改其名称而不是使用相同的名称，这可能会更容易完成。