From b43759ac85d59561684bdf0b3a56d6bf822d67c8 Mon Sep 17 00:00:00 2001 From: Ismael Juma Date: Fri, 26 Aug 2016 00:00:15 +0100 Subject: [PATCH] Improve log message in `ReplicaManager.becomeLeaderOrFollower` --- core/src/main/scala/kafka/server/ReplicaManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala index f94cbf998aba..f1cc694cd607 100644 --- a/core/src/main/scala/kafka/server/ReplicaManager.scala +++ b/core/src/main/scala/kafka/server/ReplicaManager.scala @@ -631,7 +631,7 @@ class ReplicaManager(val config: KafkaConfig, } else { // Otherwise record the error code in response stateChangeLogger.warn(("Broker %d ignoring LeaderAndIsr request from controller %d with correlation id %d " + - "epoch %d for partition [%s,%d] since its associated leader epoch %d is old. Current leader epoch is %d") + "epoch %d for partition [%s,%d] since its associated leader epoch %d is not higher than the current leader epoch %d") .format(localBrokerId, controllerId, correlationId, leaderAndISRRequest.controllerEpoch, topicPartition.topic, topicPartition.partition, stateInfo.leaderEpoch, partitionLeaderEpoch)) responseMap.put(topicPartition, Errors.STALE_CONTROLLER_EPOCH.code)