diff options
| -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])) |