diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
index 6ec1b71ed..e1ee7e514 100644
--- a/kafka/consumer/fetcher.py
+++ b/kafka/consumer/fetcher.py
@@ -29,7 +29,7 @@
 
 ConsumerRecord = collections.namedtuple("ConsumerRecord",
     ["topic", "partition", "offset", "timestamp", "timestamp_type",
-     "key", "value", "checksum", "serialized_key_size", "serialized_value_size"])
+     "key", "value", "checksum", "serialized_key_size", "serialized_value_size", "headers"])
 
 
 CompletedFetch = collections.namedtuple("CompletedFetch",
@@ -459,7 +459,7 @@ def _unpack_message_set(self, tp, records):
                     yield ConsumerRecord(
                         tp.topic, tp.partition, record.offset, record.timestamp,
                         record.timestamp_type, key, value, record.checksum,
-                        key_size, value_size)
+                        key_size, value_size, record.headers)
 
                 batch = records.next_batch()