gpt4 book ai didi

streaming - Kinesis 最新位置是如何记录的

转载 作者:行者123 更新时间:2023-12-02 10:20:18 25 4
gpt4 key购买 nike

当不使用 Kinesis 检查点时,有一个 InitialPositionInStream.LATEST 设置,据说可以让您重新启动从“最新提示”接收的 kinesis。有人可以解释一下到底是什么吗?如果接收器应用程序被关闭并重新启动,那么最新的提示信息将存储在哪里?

最佳答案

如果您使用的是最新版本,您不应该关心前一个工作人员在哪里停止。当您使用此标志时,这意味着您想要从现在开始处理记录,并且您不关心历史事件。

如果你想继续之前的worker的处理,你应该使用该worker的最后一个检查点的序列ID。

如果要处理 kinesis 流中可用的所有历史事件,则应使用 TRIM_HORIZON 标志。

请参阅分片迭代器类型的 kinesis 文档中的更多详细信息:http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html

关于streaming - Kinesis 最新位置是如何记录的,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34229391/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com