diff options
| author | Mark Roberts <wizzat@gmail.com> | 2015-02-09 10:19:24 -0800 |
|---|---|---|
| committer | Mark Roberts <wizzat@gmail.com> | 2015-02-09 10:19:24 -0800 |
| commit | 3ab9a42fcf43466f233068585f47154fbd34760b (patch) | |
| tree | 8a3d9c1cd24364bff7e157c3d95d1a17fd78fe71 | |
| parent | f206a4bbf0b0e39cf13c7c5918a99abc085d004d (diff) | |
| parent | cc6e8bbb22dc592224757d96579867c58b975803 (diff) | |
| download | kafka-python-3ab9a42fcf43466f233068585f47154fbd34760b.tar.gz | |
Merge pull request #315 from dpkp/sorted_partition_ids
Always return sorted partition ids in client.get_partition_ids_for_topic()
| -rw-r--r-- | kafka/client.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py index 7b04e71..f8fe555 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -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() |