We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cd81cf0 commit 353c01eCopy full SHA for 353c01e
kafka/consumer/kafka.py
@@ -344,7 +344,7 @@ def fetch_messages(self):
344
logger.warning('OffsetOutOfRange: topic %s, partition %d, '
345
'offset %d (Highwatermark: %d)',
346
topic, partition,
347
- self.offsets._fetch[(topic, partition)],
+ self._offsets.fetch[(topic, partition)],
348
resp.highwaterMark)
349
# Reset offset
350
self._offsets.fetch[(topic, partition)] = (
0 commit comments