apache-pulsar - 删除/过期 Apache Pulsar 主题中所有消息的最有效方法是什么？

Question

我正在尝试找出从 Pulsar 主题中删除所有消息(逻辑上或物理上)的最佳方法，以便订阅不再使用它们？

我知道我们可以简单地执行 $ pulsar-admin persistent delete persistent://tenant/namespace/topic。

但是，这个解决方案有一些缺点:它完全删除了主题(所以我们必须稍后重新创建它)然后应该没有事件的客户端连接到它(即:订阅或生产者)。

或者，有没有办法以编程方式使两个 MessageId 之间的所有消息对订阅不可用？

谢谢

Answer 1

有几个选项可供您选择。

• 您可以使用 topics skip 为给定主题的特定订阅跳过 N 条消息。 https://pulsar.apache.org/docs/en/admin-api-persistent-topics/#skip-messages

• 您可以使用 topics skip-all 跳过给定主题的特定订阅的所有旧消息。 https://pulsar.apache.org/docs/en/admin-api-persistent-topics/#skip-all-messages

• 您可以使用 topics clear-backlog 来清除特定订阅的积压。与 topics skip-all 相同。

• 您还可以使用 topics reset-cursor 将订阅光标移动到特定的消息 id 或时间戳。