如果必须在应用程序开始运行之前从流中读取消息，则应该使用哪种分片迭代器类型

问题描述

如果必须在应用程序开始运行之前从流中读取消息，则应该使用哪种分片迭代器类型

我们的代码现在看起来像这样，但是分片迭代器类型LATEST不会读取应用程序启动之前发布到流中的消息。我该如何设置？

private String getShardIterator() {

       GetShardIteratorRequest itReq = GetShardIteratorRequest.builder()

               .streamName(streamName)

               .shardIteratorType("LATEST")

               .shardId("shardId-000000000000")

               .build();

引用：https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/kinesis/model/GetShardIteratorRequest.html

解决方法

如果要阅读可用的最旧消息，则需要将分片迭代器类型设置为TRIM_HORIZON，该类型将从分片中可用的最旧记录开始。

如果您还知道开始的序列号，则可以将其设置为AT_SEQUENCE_NUMBER或AFTER_SEQUENCE_NUMBER，并另外提供起始序号参数。

LATEST从订阅后发布的最新记录开始。