diff options
| author | Arturo Filastò <art@fuffa.org> | 2015-05-14 15:49:46 +0200 |
|---|---|---|
| committer | Arturo Filastò <art@fuffa.org> | 2015-05-14 18:07:03 +0200 |
| commit | 353c01eb1caac594e4c93af352921a48f12aa20a (patch) | |
| tree | ef4561f594da4c64402145c7950f26c464398696 /kafka/consumer/kafka.py | |
| parent | cd81cf0ec8c1b7e7651374c5d1cbd105d003d352 (diff) | |
| download | kafka-python-353c01eb1caac594e4c93af352921a48f12aa20a.tar.gz | |
Fix calling of _offsets
Previously you would see this error:
```
self.offsets._fetch[(topic, partition)],
AttributeError: 'function' object has no attribute '_fetch'
```
Diffstat (limited to 'kafka/consumer/kafka.py')
| -rw-r--r-- | kafka/consumer/kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py index 47a5b00..60f1a0b 100644 --- a/kafka/consumer/kafka.py +++ b/kafka/consumer/kafka.py @@ -344,7 +344,7 @@ class KafkaConsumer(object): logger.warning('OffsetOutOfRange: topic %s, partition %d, ' 'offset %d (Highwatermark: %d)', topic, partition, - self.offsets._fetch[(topic, partition)], + self._offsets.fetch[(topic, partition)], resp.highwaterMark) # Reset offset self._offsets.fetch[(topic, partition)] = ( |