Merge pull request #376 from hellais/fix/offset

Fix calling of _offsets
dpkp · May 14, 2015 · f020c45 · f020c45
2 parents cd81cf0 + 353c01e
commit f020c45
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)] = (