根据doc Dynamodb 流和 Kinesis 数据流的低级 API 相似,但它们并非 100% 相同。
我注意到Dynamodb 流的 GetShardIterator有点不同,即它不支持AT_TIMESTAMP作为分片迭代器类型。
因此,我认为适配器实现将限制 KCL 消费者功能,并且不允许AT_TIMESTAMP起始位置。
我的推理正确吗?我还没有实现它。如果这似乎是一个障碍点,我更愿意寻找另一种解决方案。
根据doc Dynamodb 流和 Kinesis 数据流的低级 API 相似,但它们并非 100% 相同。
我注意到Dynamodb 流的 GetShardIterator有点不同,即它不支持AT_TIMESTAMP作为分片迭代器类型。
因此,我认为适配器实现将限制 KCL 消费者功能,并且不允许AT_TIMESTAMP起始位置。
我的推理正确吗?我还没有实现它。如果这似乎是一个障碍点,我更愿意寻找另一种解决方案。