From 4a5b89eedaf5c14799bb587ffa4766c4be89441b Mon Sep 17 00:00:00 2001 From: Hao Geng Date: Fri, 15 Mar 2024 13:18:11 -0700 Subject: [PATCH] [LIHOTFIX]Log client endpoint when accept connections --- core/src/main/scala/kafka/network/SocketServer.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index 690ab892aee2..5d3037a7373f 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -727,6 +727,7 @@ private[kafka] class Acceptor(val endPoint: EndPoint, try { connectionQuotas.inc(endPoint.listenerName, socketChannel.socket.getInetAddress, blockedPercentMeter) configureAcceptedSocketChannel(socketChannel) + info(s"Accepted channel from ${endPoint.connectionString}") Some(socketChannel) } catch { case e: TooManyConnectionsException =>