Rajan (and Matteo), very interesting feature. How are we going to implement this feature ? it looks like it is bound to the Schema.BYTEBUFFER implementation, the doc does not tell much about how we have to change the Schema API in order to pass the Consumer configuration to the Schema implementation.
Enrico Il giorno mar 30 mar 2021 alle ore 06:30 PengHui Li <codelipeng...@gmail.com> ha scritto: > > Nice feature, I just have some questions want to confirm. > > 1. Does the consumer returns buffer of the batch message? > 2. If returns a batch message buffer, how do we handle the flow permits? It’s > better to clarify in the proposal > > About the API, my feeling is a RawConsumer is more suitable here, users don’t > need to specify the schema when using the RawConsumer since we might occurs > schema incompatible issue when using Schema.BYTEBUFFER. So RawConsumer is > more clear for this purpose? > > Thanks, > Penghui > On Mar 30, 2021, 10:48 AM +0800, Rajan Dhabalia <rdhaba...@apache.org>, wrote: > > Hello, > > We have created a PIP-83 for Pulsar client: Message consumption with pooled > > buffer. > > > > https://github.com/apache/pulsar/wiki/PIP-83-:-Pulsar-client:-Message-consumption-with-pooled-buffer > > > > > > Thanks, > > Rajan
