diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala index 49a0fa8505c..f9c7c29bb96 100644 --- a/core/src/main/scala/kafka/server/ReplicaManager.scala +++ b/core/src/main/scala/kafka/server/ReplicaManager.scala @@ -365,10 +365,10 @@ class ReplicaManager(val config: KafkaConfig, partitionAndOffsets.put(new TopicAndPartition(partition), BrokerAndInitialOffset(leaderBroker, partition.getReplica().get.logEndOffset)) case None => - stateChangeLogger.trace("Broker %d ignored the become-follower state change with correlation id %d " + - "controller %d epoch %d for topic-partition %s since the designated leader %d " + - "cannot be found in live or shutting down brokers %s" - .format(localBrokerId, correlationId, controllerId, epoch, partition, leader, leaders)) + stateChangeLogger.trace(("Broker %d ignored the become-follower state change with correlation id %d " + + "controller %d epoch %d for topic-partition %s since the designated leader %d " + + "cannot be found in live or shutting down brokers %s") + .format(localBrokerId, correlationId, controllerId, epoch, partition, leader, leaders)) } } replicaFetcherManager.addFetcherForPartitions(partitionAndOffsets)