在 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 中重放/重置消息的主要内容,如果未能解决你的问题,请参考以下文章