From f5e5562cb7a846c21ad819e2f4302baf80bd1223 Mon Sep 17 00:00:00 2001 From: Keith So Date: Mon, 2 Nov 2020 14:55:52 +1100 Subject: [PATCH] Only try to update sensors fetch lag if the unpacked list has any elements --- kafka/consumer/fetcher.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index e4f8c1838..7ff9daf7b 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -817,8 +817,9 @@ def _parse_fetched_data(self, completed_fetch): position) unpacked = list(self._unpack_message_set(tp, records)) parsed_records = self.PartitionRecords(fetch_offset, tp, unpacked) - last_offset = unpacked[-1].offset - self._sensors.records_fetch_lag.record(highwater - last_offset) + if unpacked: + last_offset = unpacked[-1].offset + self._sensors.records_fetch_lag.record(highwater - last_offset) num_bytes = records.valid_bytes() records_count = len(unpacked) elif records.size_in_bytes() > 0: