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 > > > > > >
