diff options
Diffstat (limited to 'kafka/record/memory_records.py')
| -rw-r--r-- | kafka/record/memory_records.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/record/memory_records.py b/kafka/record/memory_records.py index a6c4b51..fc2ef2d 100644 --- a/kafka/record/memory_records.py +++ b/kafka/record/memory_records.py @@ -117,7 +117,7 @@ class MemoryRecordsBuilder(object): def __init__(self, magic, compression_type, batch_size): assert magic in [0, 1, 2], "Not supported magic" - assert compression_type in [0, 1, 2, 3], "Not valid compression type" + assert compression_type in [0, 1, 2, 3, 4], "Not valid compression type" if magic >= 2: self._builder = DefaultRecordBatchBuilder( magic=magic, compression_type=compression_type, |