diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
index 47a5b00b4..60f1a0b5a 100644
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -344,7 +344,7 @@ def fetch_messages(self):
                 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)] = (