Updated Branches:
refs/heads/0.8 ba1ceea6d -> 51966c336
KAFKA-1087 Empty topic list causes consumer to fetch metadata of all topics; reviewed by Guozhang
Wang and Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/51966c33
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/51966c33
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/51966c33
Branch: refs/heads/0.8
Commit: 51966c336f23c5477003ce394e7242940b88a80a
Parents: ba1ceea
Author: Swapnil Ghike <sghike@linkedin.com>
Authored: Mon Oct 14 20:22:12 2013 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Mon Oct 14 20:22:18 2013 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/51966c33/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
index 30a9c97..566ca46 100644
--- a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
+++ b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
@@ -55,7 +55,7 @@ class ConsumerFetcherManager(private val consumerIdString: String,
val leaderForPartitionsMap = new HashMap[TopicAndPartition, Broker]
lock.lock()
try {
- if (noLeaderPartitionSet.isEmpty) {
+ while (noLeaderPartitionSet.isEmpty) {
trace("No partition for leader election.")
cond.await()
}
|