Merge pull request #376 from hellais/fix/offset

Fix calling of _offsets

Author: dpkp

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