apache-pulsar - 如何将订阅光标倒回到 Pulsar 中的特定时间？

Question

在文档：https ://pulsar.apache.org/docs/en/concepts-clients/中，它解释了您可以从最早或最新位置开始消费者，或者您可以指定消息ID。能否支持这个要求，即指定一个时间点并从那里开始，例如，现在我想迭代从昨天 12:00 到昨天 13:00 的消息？

Answer 1

是的，您可以将订阅回退到时间偏移。该命令time的选项将允许您执行此操作：pulsar-admin persistent reset-cursor

# bin/pulsar-admin persistent reset-cursor

    reset-cursor      Reset position for subscription to position closest to timestamp or messageId
      Usage: reset-cursor [options] persistent://tenant/namespace/topic
        Options:
          --messageId, -m
             messageId to reset back to (ledgerId:entryId)
        * -s, --subscription
             Subscription to reset position on
          --time, -t
             time in minutes to reset back to (or minutes, hours,days,weeks eg:
             100m, 3h, 2d, 5w)

您还可以使用 REST 管理 API。