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