From 127c2ee58605b8430f8fcac5ba902fb383eeb21c Mon Sep 17 00:00:00 2001 From: Taras Date: Mon, 19 Mar 2018 00:24:52 +0200 Subject: Add missed raise in rare case. --- kafka/record/default_records.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/record/default_records.py b/kafka/record/default_records.py index 2bbd47e..840868a 100644 --- a/kafka/record/default_records.py +++ b/kafka/record/default_records.py @@ -237,7 +237,7 @@ class DefaultRecordBatch(DefaultRecordBase, ABCRecordBatch): # validate whether we have read all header bytes in the current record if pos - start_pos != length: - CorruptRecordException( + raise CorruptRecordException( "Invalid record size: expected to read {} bytes in record " "payload, but instead read {}".format(length, pos - start_pos)) self._pos = pos -- cgit v1.2.1