[
https://issues.apache.org/jira/browse/KAFKA-20302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edoardo Comar updated KAFKA-20302:
----------------------------------
Description:
If the configuration entry`queued.max.request.bytes` is set ,
network receives buffer are allocated from a
SimpleMemoryPool
if an exception is thrown in
SocketServer.Processor.processCompletedReceives()
e.g. an
InvalidRequestException or UnsupportedVersionException
in parseRequestHeader()
for a request that requires delayed allocation,
the buffer is never released.
*Eventually the memory pool is depleted and the broker no longer processes any
request*
was:
If the configuration entry`queued.max.request.bytes` is set ,
network receives buffer are allocated from a
SimpleMemoryPool
if an exception is thrown in
SocketServer.Processor.processCompletedReceives()
e.g. an
InvalidRequestException or UnsupportedVersionException
in parseRequestHeader()
for a request that requires delayed allocation,
the buffer is never released.
Eventually the memory pool is depleted and the broker no longer processes any
request
> Receive buffers allocated from MemoryPool may not be released if request is
> invalid
> -----------------------------------------------------------------------------------
>
> Key: KAFKA-20302
> URL: https://issues.apache.org/jira/browse/KAFKA-20302
> Project: Kafka
> Issue Type: Bug
> Components: network
> Affects Versions: 3.9.2, 4.2.0, 4.3.0, 4.1.1
> Reporter: Edoardo Comar
> Assignee: Edoardo Comar
> Priority: Critical
>
> If the configuration entry`queued.max.request.bytes` is set ,
> network receives buffer are allocated from a
> SimpleMemoryPool
>
> if an exception is thrown in
> SocketServer.Processor.processCompletedReceives()
> e.g. an
> InvalidRequestException or UnsupportedVersionException
> in parseRequestHeader()
> for a request that requires delayed allocation,
> the buffer is never released.
> *Eventually the memory pool is depleted and the broker no longer processes
> any request*
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
