在 Apache Pulsar 中重放/重置消息

Posted

技术标签:

【中文标题】在 Apache Pulsar 中重放/重置消息【英文标题】:Replay / Reset messages in Apache Pulsar 【发布时间】:2022-01-06 12:44:39 【问题描述】:

是否可以重播旧消息(在保留期内)?没有关于它的文档。我想根据时间戳或期间执行此操作。

非常感谢您提供正确方向的提示。

【问题讨论】:

【参考方案1】:

我通过手动浏览 Admin 客户端找到了答案:

 adminClient.topics().resetCursor("topictest", "sub-1", milis);

您可以通过首先检索订阅者列表来重置/重播所有消费者/订阅者:

adminClient.topics().getSubscriptions("topictest")

【讨论】:

以上是关于在 Apache Pulsar 中重放/重置消息的主要内容,如果未能解决你的问题,请参考以下文章

Apache pulsar producer接口详解

如何在 Reactjs 中重放 CSS3 动画

在 Flutter 中重放相同的 Flare 动画

无法在 J2ME 中重放声音

简介Apache Pulsar-下一代分布式消息系统

云原生时代顶流消息中间件Apache Pulsar部署实操之Pulsar IO与Pulsar SQL