diff options
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)] = ( |