You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2016/08/26 02:27:56 UTC
kafka git commit: MINOR: Improve log message in
`ReplicaManager.becomeLeaderOrFollower`
Repository: kafka
Updated Branches:
refs/heads/trunk 08ad2be0d -> c80649078
MINOR: Improve log message in `ReplicaManager.becomeLeaderOrFollower`
Author: Ismael Juma <is...@juma.me.uk>
Reviewers: Gwen Shapira
Closes #1789 from ijuma/improve-log-message-in-replica-manager
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c8064907
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c8064907
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c8064907
Branch: refs/heads/trunk
Commit: c80649078bb38f8b3a32ace2c5d4aa328bb8246b
Parents: 08ad2be
Author: Ismael Juma <is...@juma.me.uk>
Authored: Thu Aug 25 19:27:52 2016 -0700
Committer: Gwen Shapira <cs...@gmail.com>
Committed: Thu Aug 25 19:27:52 2016 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/server/ReplicaManager.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/c8064907/core/src/main/scala/kafka/server/ReplicaManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
index f94cbf9..f1cc694 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)