kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-787 Simple Consumer connecting to Broker that is not the Leader generates wrong error; reviewed by Jun Rao
Date Fri, 08 Mar 2013 02:31:28 GMT
Updated Branches:
  refs/heads/0.8 19ae1959b -> 5a275b077


KAFKA-787 Simple Consumer connecting to Broker that is not the Leader generates wrong error;
reviewed by Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5a275b07
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5a275b07
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5a275b07

Branch: refs/heads/0.8
Commit: 5a275b077af41803e22e5ac53a1fe474c53116ff
Parents: 19ae195
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Thu Mar 7 18:31:20 2013 -0800
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Thu Mar 7 18:31:20 2013 -0800

----------------------------------------------------------------------
 .../main/scala/kafka/server/ReplicaManager.scala   |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/5a275b07/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 e73e529..53e34ec 100644
--- a/core/src/main/scala/kafka/server/ReplicaManager.scala
+++ b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -176,7 +176,7 @@ class ReplicaManager(val config: KafkaConfig,
         partition.leaderReplicaIfLocal match {
           case Some(leaderReplica) => leaderReplica
           case None =>
-            throw new LeaderNotAvailableException("Leader not local for topic %s partition
%d on broker %d"
+            throw new NotLeaderForPartitionException("Leader not local for topic %s partition
%d on broker %d"
                     .format(topic, partitionId, config.brokerId))
         }
     }


Mime
View raw message