In the future, I will add a config for `BatchReceivePolicy.class`, I haven't thought of a name yet. The config will control the `MultiTopicsConsumerImpl.class` whether use `ConsumerImpl.class`.batchReceive() directly or use `ConsumerBase.class` `incomingMessages`.
Asaf Mesika <asaf.mes...@gmail.com> 于2022年11月8日周二 21:30写道： > > Ok. > > I would list what you wrote in your original PIP for context. > > What is your future improvement you plan? > > On Thu, Nov 3, 2022 at 11:46 AM 丛搏 <congbobo...@gmail.com> wrote: > > > Good question! > > It is a scene for our subsequent optimization, and we are implementing > > it with minimal changes. > > > > Asaf Mesika <asaf.mes...@gmail.com> 于2022年11月3日周四 16:49写道： > > > > > > Regarding the implementation suggested in the PIP: > > > > > > It said that you will read the messages from all partitions assigned, and > > > once you see a message from a different partition you halt and supply the > > > batch. > > > My question is: Why can't we simply read the messages from one partition > > > (say 10 messages) and then the next read from the other partition? > > The amount of data in a partition is not large, and there are many > > partitions. In this scenario, this method may have a large delay. > > > > > > On Thu, Oct 27, 2022 at 3:36 PM Haiting Jiang <jianghait...@gmail.com> > > > wrote: > > > > > > > +1 > > > > > > > > Haiting > > > > > > > > On Thu, Oct 27, 2022 at 5:55 PM Yubiao Feng > > > > <yubiao.f...@streamnative.io.invalid> wrote: > > > > > > > > > > +1 > > > > > > > > > > On Tue, Oct 25, 2022 at 12:25 PM 丛搏 <bog...@apache.org> wrote: > > > > > > > > > > > Hi, pulsar community: > > > > > > > > > > > > I start a PIP about `User-friendly acknowledgeCumulative API on a > > > > > > partitioned topic or multi-topics` > > > > > > > > > > > > discuss thread: > > > > > > https://lists.apache.org/thread/30rwksz4gmvgspkgcfsk708sgb1n7vbo > > > > > > https://lists.apache.org/thread/k090ftlqc149yr1cnprxb29vxg160131 > > > > > > > > > > > > PIP: https://github.com/apache/pulsar/issues/18182 > > > > > > > > > > > > Thanks, > > > > > > bo > > > > > > > > > > > >
