diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index 690ab892aee22..5d3037a7373f2 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 =>