dekaf: Use ControlMessageType of -1 to reduce the chance of it incorr…

…ectly getting assigned meaning later on
estuary · Oct 22, 2024 · f0eb24f · f0eb24f
1 parent 86ef481
commit f0eb24f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/crates/dekaf/src/read.rs b/crates/dekaf/src/read.rs
@@ -229,8 +229,8 @@ impl Read {
                 // Control Message keys are always 4 bytes:
                 // Version: 0i16
                 buf.put_i16(0);
-                // ControlMessageType: >1 i16
-                buf.put_i16(2);
+                // ControlMessageType: != 0 or 1 i16
+                buf.put_i16(-1);
                 record_bytes += buf.len();
                 Some(buf.split().freeze())
             } else {