diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala b/core/src/main/scala/kafka/network/RequestChannel.scala index aba46474867f8..a16e03a1916d4 100644 --- a/core/src/main/scala/kafka/network/RequestChannel.scala +++ b/core/src/main/scala/kafka/network/RequestChannel.scala @@ -261,7 +261,7 @@ object RequestChannel extends Logging { apiRemoteTimeMs, apiThrottleTimeMs, responseQueueTimeMs, responseSendTimeMs, temporaryMemoryBytes, messageConversionsTimeMs) - val logPrefix = "Completed request: {}" + val logPrefix = "Completed request:{}" // log deprecated apis at `info` level to allow them to be selectively enabled if (header.isApiVersionDeprecated()) requestLogger.info(logPrefix, desc)