CODEWITHSUNDEEP
c#websocketapache-pulsar
Sylens
Sylens

Reputation: 1177

Fetch Apache Pulsar unacknowledged messages

I have a persistent topic in Pulsar which has 200 messages. The first 100 messages are acknowledged but the rest of them are not. I am using WebSockets to connect to Pulsar topics to read them.

Here is my question: When I create a new Reader it does not seem to fetch the 100 messages that were not unacknowledged. It will only fetch new messages that were queued after making the reader.

How can I retrieve the old unacknowledged messages by using a reader? This setup works when I use a Consumer.

Upvotes: 2

Views: 778

Answers (1)

Krishna
Krishna

Reputation: 11

Looks like your messages are in backlog we can always check the stats of the topic and try changing the subscription name. And Instead of using Web-socket using pulsar client node is lot ore easier everything is documented in the apache pulsar docs.

Upvotes: 1

Related Questions