0xffff-zhiyan opened a new pull request, #22678: URL: https://github.com/apache/kafka/pull/22678
KRaftControlRecordStateMachine reused a single BufferSupplier across all reads. The supplier returned by BufferSupplier.create() caches ByteBuffers by capacity without eviction, so the cached buffers lived as long as the state machine and consumed memory unboundedly. Create a fresh BufferSupplier per read in maybeLoadLog() and maybeLoadSnapshot() instead, allowing it to be released once the read completes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
