在 Apache Pulsar 中重播/重置消息

Question

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

如能提供正确方向的提示，我们将不胜感激。

Answer 1

我通过管理客户端手动找到了答案：

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

您可以 reset/replay 所有 consumers/subscribers 通过首先检索订阅者列表：

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

Replay / Reset messages in Apache Pulsar