diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala index 4ee24f2e41428..777df3b125c22 100644 --- a/core/src/main/scala/kafka/server/ReplicaManager.scala +++ b/core/src/main/scala/kafka/server/ReplicaManager.scala @@ -2542,7 +2542,9 @@ class ReplicaManager(val config: KafkaConfig, } replicaFetcherManager.addFetcherForPartitions(partitionAndOffsets) - stateChangeLogger.info(s"Started fetchers as part of become-follower for ${partitionsToStartFetching.size} partitions") + if (partitionAndOffsets.nonEmpty) { + stateChangeLogger.info(s"Started fetchers as part of become-follower for ${partitionAndOffsets.size} partitions") + } partitionsToStartFetching.foreach{ case (topicPartition, partition) => completeDelayedOperationsWhenNotPartitionLeader(topicPartition, partition.topicId)}