【发布时间】:2020-08-04 12:54:12
【问题描述】:
根据doc Dynamodb 流和 Kinesis 数据流的低级 API 相似,但它们并非 100% 相同。
我注意到 Dynamodb streams' GetShardIterator 有点不同,即它不支持将 AT_TIMESTAMP 作为分片迭代器类型。
因此,我认为适配器实现会限制 KCL 消费者功能,并且不允许 AT_TIMESTAMP 起始位置。
我的推理正确吗?我还没有实现它。如果这似乎是一个阻塞点,我更愿意寻找其他解决方案。
【问题讨论】:
标签: amazon-dynamodb amazon-kinesis amazon-dynamodb-streams amazon-kcl