From 8e1741edcf368e4eba6af6a7218f788d4aafcee8 Mon Sep 17 00:00:00 2001 From: Francois Chartier Date: Fri, 20 Jul 2018 20:36:39 +0200 Subject: [PATCH] include headers in fetcher results --- kafka/consumer/fetcher.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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()