openstack/deb-python-kafka
Code Issues Proposed changes

Always return sorted partition ids in KafkaClient.get_partition_ids_for_topic()

Browse Source
This commit is contained in:
Dana Powers
2015-02-08 21:35:16 -08:00
parent f206a4bbf0
commit cc6e8bbb22
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/client.py
View File

@@ -261,7 +261,7 @@ class KafkaClient(object):
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()