diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-03-02 09:37:55 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-03-02 09:37:55 -0800 |
| commit | c80fbd1451f0042a28eba537c7b804c92bfbd612 (patch) | |
| tree | 8194ba7e3ea681aa54a0f2dffde1e3cb4a95beb4 | |
| parent | 83d28ba79a5453abf0530e403c125e51b9d3641c (diff) | |
| download | kafka-python-c80fbd1451f0042a28eba537c7b804c92bfbd612.tar.gz | |
KafkaClient.get_partition_ids_for_topic now returns empty list for unknown topics
| -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 6c6e74f..48a534e 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -265,7 +265,7 @@ class KafkaClient(object): def get_partition_ids_for_topic(self, topic): if topic not in self.topic_partitions: - return None + return [] return sorted(list(self.topic_partitions[topic])) |