获取 Apache Pulsar 未确认的消息

Question

我在 Pulsar 中有一个持久主题，它有 200 条消息。前 100 条消息得到确认，但其余消息未得到确认。我正在使用 WebSockets 连接到 Pulsar 主题以阅读它们。

这是我的问题： 当我创建一个新的 Reader 时，它似乎没有获取 100 条未被确认的消息。它只会获取读取器后排队的新消息。

如何使用阅读器检索旧的未确认消息？当我使用 Consumer 时，此设置有效。

Answer 1

看起来您的消息在积压中，我们可以随时检查主题的统计信息并尝试更改订阅名称。 并且使用 pulsar 客户端节点而不是使用 Web-socket 更容易，所有内容都记录在 apache pulsar 文档中。