Получение неподтвержденных сообщений Apache Pulsar

У меня есть постоянная тема в Pulsar, в которой 200 сообщений. Первые 100 сообщений подтверждаются, а остальные нет. Я использую WebSockets, чтобы подключиться к темам Pulsar и прочитать их.

Вот мой вопрос: когда я создаю новый Reader, кажется, что он не получает 100 сообщений, которые не были неподтвержденными. Он будет получать только новые сообщения, которые были поставлены в очередь после создания читателя.

Как я могу получить старые неподтвержденные сообщения с помощью ридера? Эта настройка работает, когда я использую Consumer.


person Sylens    schedule 16.11.2019    source источник
comment
Когда средство чтения создано, вы можете указать startMessageId, из которого можно прочитать сообщение. Если после создания считывателя в очередь были поставлены только новые сообщения, вы указали MessageId.latest в startMessageId?   -  person Ming L.    schedule 14.01.2020


Ответы (1)


Похоже, что ваши сообщения находятся в очереди, мы всегда можем проверить статистику по теме и попробовать изменить название подписки. И вместо использования веб-сокета с использованием клиентского узла Pulsar намного проще, все задокументировано в документации apache pulsar.

person Krishna    schedule 16.04.2020