kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [08/27] git commit: KAFKA-787 Simple Consumer connecting to Broker that is not the Leader generates wrong error; reviewed by Jun Rao
Date Thu, 18 Apr 2013 04:54:02 GMT
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/trunk
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