kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-1062 Reading topic metadata from zookeeper leads to incompatible ordering of partition list; reviewed by Neha and Guozhang
Date Fri, 20 Sep 2013 16:56:34 GMT
Updated Branches:
  refs/heads/0.8 d6f95cf97 -> 61b8b2bf8


KAFKA-1062 Reading topic metadata from zookeeper leads to incompatible ordering of partition
list; reviewed by Neha and Guozhang


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/61b8b2bf
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/61b8b2bf
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/61b8b2bf

Branch: refs/heads/0.8
Commit: 61b8b2bf818c36e5844a32b24b2855c32bd34254
Parents: d6f95cf
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Fri Sep 20 09:56:28 2013 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Fri Sep 20 09:56:28 2013 -0700

----------------------------------------------------------------------
 .../src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/61b8b2bf/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala b/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
index 881f51e..08b4b72 100644
--- a/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
+++ b/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
@@ -422,7 +422,7 @@ private[kafka] class ZookeeperConsumerConnector(val config: ConsumerConfig,
       }
       else {
         val partitionsAssignmentPerTopicMap = getPartitionAssignmentForTopics(zkClient, myTopicThreadIdsMap.keySet.toSeq)
-        val partitionsPerTopicMap = partitionsAssignmentPerTopicMap.map(p => (p._1, p._2.keySet.toSeq))
+        val partitionsPerTopicMap = partitionsAssignmentPerTopicMap.map(p => (p._1, p._2.keySet.toSeq.sorted))
 
         /**
          * fetchers must be stopped to avoid data duplication, since if the current


Mime
View raw message