diff options
| -rw-r--r-- | kafka/record/default_records.py | 2 |
1 files changed, 1 insertions, 1 deletions
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 |