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 16:30:36 GMT
Updated Branches:
  refs/heads/trunk 3e7c9c6ab -> 062d910e3


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/062d910e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/062d910e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/062d910e

Branch: refs/heads/trunk
Commit: 062d910e3235ef71b1e7a01472f4360658c83bea
Parents: 3e7c9c6
Author: Swapnil Ghike <sghike@linkedin.com>
Authored: Tue Oct 15 09:30:22 2013 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Tue Oct 15 09:30:28 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/062d910e/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 8c03308..4e76367 100644
--- a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
+++ b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
@@ -54,7 +54,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