From 618c36aca865e7910d017524e826c92f727e6e71 Mon Sep 17 00:00:00 2001
From: Lucas Kent <rubickent@gmail.com>
Date: Tue, 14 Mar 2023 10:46:03 +1100
Subject: [PATCH] Another kafka fix (#1078)

Co-authored-by: Conor <conor.brosnan@instaclustr.com>
---
 shotover-proxy/src/codec/kafka.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/shotover-proxy/src/codec/kafka.rs b/shotover-proxy/src/codec/kafka.rs
index 9bbb40580..3f8577f99 100644
--- 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