Fix flake

tvoinarovskyi · tvoinarovskyi · commit ba9b11ccca6b · 2017-09-12T20:38:59.000Z
diff --git a/kafka/record/legacy_records.py b/kafka/record/legacy_records.py
@@ -105,7 +105,7 @@ def compression_type(self):
         return self._attributes & self.CODEC_MASK
 
     def validate_crc(self):
-        crc = calc_crc32(self.buffer[self.MAGIC_OFFSET:])
+        crc = calc_crc32(self._buffer[self.MAGIC_OFFSET:])
         return self._crc == crc
 
     def _decompress(self, key_offset):
