Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-11-08 Thread 丛搏
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 于2022年11月8日周二 21:30写

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-11-08 Thread Asaf Mesika
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 丛搏 wrote: > Good question! > It is a scene for our subsequent optimization, and we are implementing > it with minimal changes. > > Asaf Mesika 于2022年11月3

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-11-03 Thread 丛搏
Good question! It is a scene for our subsequent optimization, and we are implementing it with minimal changes. Asaf Mesika 于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 m

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-11-03 Thread Asaf Mesika
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) a

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-10-27 Thread Haiting Jiang
+1 Haiting On Thu, Oct 27, 2022 at 5:55 PM Yubiao Feng wrote: > > +1 > > On Tue, Oct 25, 2022 at 12:25 PM 丛搏 wrote: > > > Hi, pulsar community: > > > > I start a PIP about `User-friendly acknowledgeCumulative API on a > > partitioned topic or multi-topics` > > > > discuss thread: > > https://li

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-10-27 Thread Yubiao Feng
+1 On Tue, Oct 25, 2022 at 12:25 PM 丛搏 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/threa

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-10-26 Thread Yunze Xu
+1 Thanks, Yunze On Wed, Oct 26, 2022 at 12:06 PM Qiang Huang wrote: > > +1 > > Enrico Olivelli 于2022年10月25日周二 22:32写道: > > > +1 > > > > awesome work > > > > Enrico > > > > Il giorno mar 25 ott 2022 alle ore 16:28 PengHui Li > > ha scritto: > > > > > > +1 > > > > > > Penghui > > > > > > On Tue

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-10-25 Thread Qiang Huang
+1 Enrico Olivelli 于2022年10月25日周二 22:32写道: > +1 > > awesome work > > Enrico > > Il giorno mar 25 ott 2022 alle ore 16:28 PengHui Li > ha scritto: > > > > +1 > > > > Penghui > > > > On Tue, Oct 25, 2022 at 12:25 PM 丛搏 wrote: > > > > > Hi, pulsar community: > > > > > > I start a PIP about `User-

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-10-25 Thread Enrico Olivelli
+1 awesome work Enrico Il giorno mar 25 ott 2022 alle ore 16:28 PengHui Li ha scritto: > > +1 > > Penghui > > On Tue, Oct 25, 2022 at 12:25 PM 丛搏 wrote: > > > Hi, pulsar community: > > > > I start a PIP about `User-friendly acknowledgeCumulative API on a > > partitioned topic or multi-topics`

Re: [DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-10-25 Thread PengHui Li
+1 Penghui On Tue, Oct 25, 2022 at 12:25 PM 丛搏 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.

[DISCUSS] PIP-218: Consumer batchReceive() single partition every receive

2022-10-24 Thread 丛搏
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/apa