From c80fbd1451f0042a28eba537c7b804c92bfbd612 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Mon, 2 Mar 2015 09:37:55 -0800
Subject: KafkaClient.get_partition_ids_for_topic now returns empty list for
 unknown topics

---
 kafka/client.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'kafka/client.py')

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]))
 
-- 
cgit v1.2.1