diff --git a/crates/derive/src/stages/channel_reader.rs b/crates/derive/src/stages/channel_reader.rs index 64a7c8ca2..4dc1f0f30 100644 --- a/crates/derive/src/stages/channel_reader.rs +++ b/crates/derive/src/stages/channel_reader.rs @@ -171,7 +171,7 @@ impl BatchReader { self.decompressed = decompress_to_vec_zlib(&data).ok()?; } else if compression_type == CHANNEL_VERSION_BROTLI { brotli_used = true; - self.decompressed = decompress_brotli(&data).ok()?; + self.decompressed = decompress_brotli(&data[1..]).ok()?; } else { tracing::error!(target: "batch-reader", "Unsupported compression type: {:x}, skipping batch", compression_type); return None;