Chia-Ping Tsai created KAFKA-21092:
--------------------------------------
Summary: The closed processor should remove the channel builder
from reconfigurable list
Key: KAFKA-21092
URL: https://issues.apache.org/jira/browse/KAFKA-21092
Project: Kafka
Issue Type: Bug
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{code:java}
protected[network] def createSelector(channelBuilder: ChannelBuilder):
KSelector = {
channelBuilder match {
case reconfigurable: Reconfigurable =>
config.addReconfigurable(reconfigurable)
case _ =>
}
new KSelector(
maxRequestSize,
connectionsMaxIdleMs,
failedAuthenticationDelayMs,
metrics,
time,
"socket-server",
metricTags,
false,
true,
channelBuilder,
memoryPool,
logContext)
} {code}
The processor lets Selector control the life of ChannelBuilder, but Selector
can't remove the ChannelBuilder from the reconfigurable list. It is probably a
kind of leak that the closed ChannelBuilder is still in the list.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
