使用 Dynamodb 流 kinesis 适配器时,Kinesis Client Library 消费者是否支持 AT_TIMESTAMP 作为起始位置

Does Kinesis Client Library consumer support AT_TIMESTAMP as a starting position when using Dynamodb streams kinesis adapter

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

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

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

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

Kinesis 客户端库使用者在使用 Dynamodb 流 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