0

根据doc Dynamodb 流和 Kinesis 数据流的低级 API 相似,但它们并非 100% 相同。

我注意到Dynamodb 流的 GetShardIterator有点不同,即它不支持AT_TIMESTAMP作为分片迭代器类型。

因此,我认为适配器实现将限制 KCL 消费者功能,并且不允许AT_TIMESTAMP起始位置。

我的推理正确吗?我还没有实现它。如果这似乎是一个障碍点,我更愿意寻找另一种解决方案。

4

1 回答 1

0

使用 Dynamodb 流 Kinesis 适配器时,Kinesis 客户端库使用者不支持将 AT_TIMESTAMP 作为起始位置:

https://github.com/awslabs/dynamodb-streams-kinesis-adapter/blob/50750146b1ccc1d87793522780ca21b4e376b2e1/src/main/java/com/amazonaws/services/dynamodbv2/streamsadapter/model/GetShardIteratorRequestAdapter.java#L142

于 2020-08-04T14:36:26.307 回答