kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-1087 Empty topic list causes consumer to fetch metadata of all topics; reviewed by Guozhang Wang and Neha Narkhede
Date Tue, 15 Oct 2013 03:22:34 GMT
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()
         }


Mime
View raw message