Kinesis LATEST 位置是如何记录的
how is Kinesis LATEST position recorded
当不使用 Kinesis 检查点时,有一个 InitialPositionInStream.LATEST 设置可以让您重新启动从 "latest tip" 接收的 Kinesis。有人可以解释一下那到底是什么。如果接收器应用程序关闭并重新启动,那么为此目的,最新的提示信息将存储在哪里?
如果您使用的是 LATEST,您不应该关心前一个工作人员在哪里停下来。当您使用此标志时,这意味着您希望从现在开始处理记录并且您不关心历史事件。
如果你想继续前一个worker的处理,你应该使用那个worker最后一个检查点的序列ID。
如果您想处理运动流中可用的所有历史事件,您应该使用 TRIM_HORIZON 标志。
在 kinesis 文档中查看有关分片迭代器类型的更多详细信息:http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html
当不使用 Kinesis 检查点时,有一个 InitialPositionInStream.LATEST 设置可以让您重新启动从 "latest tip" 接收的 Kinesis。有人可以解释一下那到底是什么。如果接收器应用程序关闭并重新启动,那么为此目的,最新的提示信息将存储在哪里?
如果您使用的是 LATEST,您不应该关心前一个工作人员在哪里停下来。当您使用此标志时,这意味着您希望从现在开始处理记录并且您不关心历史事件。
如果你想继续前一个worker的处理,你应该使用那个worker最后一个检查点的序列ID。
如果您想处理运动流中可用的所有历史事件,您应该使用 TRIM_HORIZON 标志。
在 kinesis 文档中查看有关分片迭代器类型的更多详细信息:http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html