summaryrefslogtreecommitdiff
path: root/kafka/consumer.py
diff options
context:
space:
mode:
authorThomas Dimson <tdimson@gmail.com>2014-01-13 15:30:51 -0800
committerThomas Dimson <tdimson@gmail.com>2014-01-13 15:38:46 -0800
commit9c7b41283851735cbee5092f2923d7c8a006b89a (patch)
tree2ecf49bc2a9251378b76bc64ae1f26e4fa4c42a3 /kafka/consumer.py
parent87c7f9dedfc008e3fff7a010cc4e708eeec5bebe (diff)
downloadkafka-python-9c7b41283851735cbee5092f2923d7c8a006b89a.tar.gz
Exception hierarchy, invalidate more md on errors
Diffstat (limited to 'kafka/consumer.py')
-rw-r--r--kafka/consumer.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py
index eba2912..522d6ca 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -76,7 +76,7 @@ class Consumer(object):
self.client = client
self.topic = topic
self.group = group
- self.client._load_metadata_for_topics(topic)
+ self.client.load_metadata_for_topics(topic)
self.offsets = {}
if not partitions: