From e0e1160913aa813dd2e7e04e2cbdc44a6af0d387 Mon Sep 17 00:00:00 2001
From: Joseph Shearer <joseph@josephshearer.net>
Date: Fri, 20 Sep 2024 16:11:39 -0400
Subject: [PATCH] dekaf: Temporarily disable record LZ4 compression

---
 crates/dekaf/src/read.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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)