This message was deleted.
# general
s
This message was deleted.
k
My goal is to filter messages based on backlog size. If I'm having 10k msg in my backlog I want to filter specified message and process them later. Maybe the receiverqueue length can be enough, wdyt?
j
Maybee in msgBacklog while querying stats : https://pulsar.apache.org/docs/next/admin-api-topics/#get-stats
a
That should work
There was a pip related to this recently