Hi Bo I think this is a good way to filter messages that the client has received.
And I have two questions: 1. This is more powerful than the original way (`acknowledgmentsGroupingTracker.isDuplicate(msgId)) to filter out duplicated messages. Is it possible to turn off the original de-replay logic to improve performance after enabling this new feature? 2. There should be a typo in the article > ## Only support Consumer#redeliverUnacknowledgedMessages() > If we redeliver individual messages, they will be filtered. Because we can't clear the record latest message >in the consumer when redelivering individual messages. It will make this config unclear, and if every redeliver > method changes, it will bring a lot of redundant code, which is difficult to maintain. If there is a need in the > future, just support it. I suppose you want to say not support `redeliverUnacknowledgedMessages`, right? Thanks Yubiao Feng On Mon, Mar 20, 2023 at 10:21 PM 丛搏 <congbobo...@gmail.com> wrote: > Hi, pulsar community: > > I started a PIP about `Client consumer filter received messages`. > > PIP: https://github.com/apache/pulsar/issues/19864 > > Thanks, > Bo >
