Hi Kafka Dev Team, It seems that Maximum buffer size is set to 2 default. What is impact of changing this to 2000 or so ? This will improve the consumer thread performance ? More event will be buffered in memory. Or Is there any other recommendation to tune High Level Consumers ?
Here is code from Kafka Trunk Branch: val MaxQueuedChunks = 2 /** max number of message chunks buffered for consumption, each chunk can be up to fetch.message.max.bytes*/ val queuedMaxMessages = props.getInt("queued.max.message.chunks", MaxQueuedChunks) Thanks, Bhavesh