diff --git a/src/log_batch.rs b/src/log_batch.rs index edd4e32c..da5a9cf7 100644 --- a/src/log_batch.rs +++ b/src/log_batch.rs @@ -591,12 +591,7 @@ where item.encode_to::(&mut vec).unwrap(); } - let compression_type = if vec.len() > COMPRESSION_SIZE { - vec = lz4::encode_block(&vec[HEADER_LEN..], HEADER_LEN, 4); - CompressionType::Lz4 - } else { - CompressionType::None - }; + let compression_type = CompressionType::None; let checksum = crc32(&vec[8..]); vec.encode_u32_le(checksum).unwrap();