Hi, Yubiao : Yubiao Feng <yubiao.f...@streamnative.io.invalid> 于2023年3月20日周一 22:53写道： > > 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? > Good question! Yes, the original (`acknowledgmentsGroupingTracker.isDuplicate(msgId)) works for duplicated messages, we can turn off the original de-replay logic to improve. in this PIP, only consider the function, this improvement can be done later
> 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? we only support `redeliverUnacknowledgedMessages` to clear the record in client consumer, any other redeliver method doesn't support > > > 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 > >
