diff --git a/crates/dekaf/src/read.rs b/crates/dekaf/src/read.rs index 70115154ab..7a70fe904d 100644 --- a/crates/dekaf/src/read.rs +++ b/crates/dekaf/src/read.rs @@ -252,7 +252,7 @@ impl Read { } let opts = RecordEncodeOptions { - compression: Compression::Lz4, + compression: Compression::None, version: 2, }; RecordBatchEncoder::encode(&mut buf, records.iter(), &opts)