diff options
| author | Taras <voyn1991@gmail.com> | 2018-03-19 00:24:52 +0200 |
|---|---|---|
| committer | Taras <voyn1991@gmail.com> | 2018-03-19 00:24:52 +0200 |
| commit | 127c2ee58605b8430f8fcac5ba902fb383eeb21c (patch) | |
| tree | 120c333cab43766ee21ebc2cd05fc8ce6d8521c0 | |
| parent | 0713034b090f979eb73003e11a406dc660e6ae3e (diff) | |
| download | kafka-python-fix_memory_records_typo.tar.gz | |
Add missed raise in rare case.fix_memory_records_typo
| -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 |