Merge pull request #315 from dpkp/sorted_partition_ids

Always return sorted partition ids in client.get_partition_ids_for_topic()

Author: wizzat

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()