diff options
Diffstat (limited to 'kafka/client.py')
| -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 3c2a727..53b6ad0 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -86,7 +86,7 @@ class KafkaClient(object): self.load_metadata_for_topics(topic) # If the partition doesn't actually exist, raise - if partition not in self.topic_partitions[topic]: + if partition not in self.topic_partitions.get(topic, []): raise UnknownTopicOrPartitionError(key) # If there's no leader for the partition, raise |