Как перемотать курсор подписки на указанное c время в Pulsar?

Question

В документе: https://pulsar.apache.org/docs/en/concepts-clients/ объясняется, что вы можете начать потребителя с самой ранней или последней позиции или указать идентификатор сообщения. Может ли оно поддерживать это требование, например, чтобы указать момент времени и начать оттуда, теперь я хочу перебирать сообщения со вчерашнего 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)

Вы также можете использовать API администратора REST.