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 <[email protected]> Authored: Fri Sep 20 09:56:28 2013 -0700 Committer: Neha Narkhede <[email protected]> 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
