fix(issues1999): fix Processor.channelContexts memory leak (#2000)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Sep 9, 2024 · 2b5e703 · 2b5e703
1 parent e077118
commit 2b5e703
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -1267,6 +1267,7 @@ private[kafka] class Processor(
           val remove = connectionId.equals(e.getValue.request.context.connectionId)
           remove
         })
+        channelContexts.remove(connectionId)
         // the channel has been closed by the selector but the quotas still need to be updated
         connectionQuotas.dec(listenerName, InetAddress.getByName(remoteHost))
       } catch {