Always return sorted partition ids in KafkaClient.get_partition_ids_f…

…or_topic()
dpkp · Feb 9, 2015 · 0c0c66b · 0c0c66b
1 parent 87f3e10
commit 0c0c66b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/client.py b/kafka/client.py
@@ -261,7 +261,7 @@ def get_partition_ids_for_topic(self, topic):
         if topic not in self.topic_partitions:
             return None
 
-        return list(self.topic_partitions[topic])
+        return sorted(list(self.topic_partitions[topic]))
 
     def ensure_topic_exists(self, topic, timeout = 30):
         start_time = time.time()