You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ne...@apache.org on 2013/09/20 18:56:34 UTC
git commit: KAFKA-1062 Reading topic metadata from zookeeper leads to
incompatible ordering of partition list; reviewed by Neha and Guozhang
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 <ne...@gmail.com>
Authored: Fri Sep 20 09:56:28 2013 -0700
Committer: Neha Narkhede <ne...@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