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.narkh...@gmail.com> Authored: Thu Mar 7 18:31:20 2013 -0800 Committer: Neha Narkhede <neha.narkh...@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)) } }
