使用 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 作为起始位置:
根据 doc Dynamodb 流和 Kinesis 数据流低级 API 相似,但它们并非 100% 相同。
我注意到 Dynamodb streams' GetShardIterator 有点不同,即它不支持 AT_TIMESTAMP 作为分片迭代器类型。
因此,我认为适配器实施将限制 KCL 消费者功能,并且不允许 AT_TIMESTAMP 起始位置。
我的推理是否正确?我还没有实施它。如果这似乎是一个障碍点,我更愿意寻找其他解决方案。
Kinesis 客户端库使用者在使用 Dynamodb 流 kinesis 适配器时不支持 AT_TIMESTAMP 作为起始位置: