如何解决如果必须在应用程序开始运行之前从流中读取消息,则应该使用哪种分片迭代器类型
如果必须在应用程序开始运行之前从流中读取消息,则应该使用哪种分片迭代器类型
我们的代码现在看起来像这样,但是分片迭代器类型LATEST不会读取应用程序启动之前发布到流中的消息。我该如何设置?
private String getShardIterator() {
GetShardIteratorRequest itReq = GetShardIteratorRequest.builder()
.streamName(streamName)
.shardIteratorType("LATEST")
.shardId("shardId-000000000000")
.build();
解决方法
如果要阅读可用的最旧消息,则需要将分片迭代器类型设置为TRIM_HORIZON
,该类型将从分片中可用的最旧记录开始。
如果您还知道开始的序列号,则可以将其设置为AT_SEQUENCE_NUMBER
或AFTER_SEQUENCE_NUMBER
,并另外提供起始序号参数。
LATEST
从订阅后发布的最新记录开始。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。