diff options
| author | kvfi <mail@ouafi.net> | 2020-02-24 14:21:30 +0100 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2020-03-02 08:52:04 -0800 |
| commit | d1dfb6dbf8ba108c1015ddb7245683dd946bd9ab (patch) | |
| tree | e2124857ce0d74d73ec702d9d97c0fa616c9ef62 | |
| parent | 615b9e03b9a07381c8e382839c6f2772ec49586f (diff) | |
| download | kafka-python-d1dfb6dbf8ba108c1015ddb7245683dd946bd9ab.tar.gz | |
Set length of header value to 0 if None
| -rw-r--r-- | kafka/consumer/fetcher.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 5cb25f2..2c11eb9 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -474,7 +474,9 @@ class Fetcher(six.Iterator): self.config['value_deserializer'], tp.topic, record.value) headers = record.headers - header_size = sum(len(h_key.encode("utf-8")) + len(h_val) for h_key, h_val in headers) if headers else -1 + header_size = sum( + len(h_key.encode("utf-8")) + (len(h_val) if h_val is not None else 0) for h_key, h_val in + headers) if headers else -1 yield ConsumerRecord( tp.topic, tp.partition, record.offset, record.timestamp, record.timestamp_type, key, value, headers, record.checksum, |