Another kafka fix (#1078)

Co-authored-by: Conor <conor.brosnan@instaclustr.com>
shotover · Mar 13, 2023 · 618c36a · 618c36a
1 parent 4d19376
commit 618c36a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/shotover-proxy/src/codec/kafka.rs b/shotover-proxy/src/codec/kafka.rs
@@ -65,10 +65,10 @@ impl KafkaDecoder {
     }
 }
 
-fn get_length_of_full_message(src: &mut BytesMut) -> Option<usize> {
+fn get_length_of_full_message(src: &BytesMut) -> Option<usize> {
     if src.len() > 4 {
         let size = u32::from_be_bytes(src[0..4].try_into().unwrap()) as usize + 4;
-        if size >= src.len() {
+        if size <= src.len() {
             Some(size)
         } else {
             None