diff options
author | Thomas Dimson <tdimson@gmail.com> | 2014-01-13 15:30:51 -0800 |
---|---|---|
committer | Thomas Dimson <tdimson@gmail.com> | 2014-01-13 15:38:46 -0800 |
commit | 9c7b41283851735cbee5092f2923d7c8a006b89a (patch) | |
tree | 2ecf49bc2a9251378b76bc64ae1f26e4fa4c42a3 /kafka/consumer.py | |
parent | 87c7f9dedfc008e3fff7a010cc4e708eeec5bebe (diff) | |
download | kafka-python-9c7b41283851735cbee5092f2923d7c8a006b89a.tar.gz |
Exception hierarchy, invalidate more md on errors
Diffstat (limited to 'kafka/consumer.py')
-rw-r--r-- | kafka/consumer.py | 2 |
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: |