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