[LIHOTFIX]Log client endpoint when accept connections

linkedin · Mar 15, 2024 · 4a5b89e · 4a5b89e
1 parent 0b55520
commit 4a5b89e
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
@@ -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 =>