【发布时间】:2019-09-12 08:07:09
【问题描述】:
我有一个 Kinesis 流处于活动状态并正在运行,我使用 KCL 库为其编写了一个生产者和一个消费者。 有没有可能使用序列号和分区键来访问特定记录的方法?
【问题讨论】:
-
您的特定用例是什么?
我有一个 Kinesis 流处于活动状态并正在运行,我使用 KCL 库为其编写了一个生产者和一个消费者。 有没有可能使用序列号和分区键来访问特定记录的方法?
【问题讨论】:
这似乎不可能。
通过GetRecords() 使用分片,它要么从开头开始,要么从前一个调用继续。无法根据序列号“跳转”到记录。
【讨论】: