fix Kafka consumer message too large

Author: matthieugouel

src/client/producer.rs

@@ -16,7 +16,7 @@ fn create_messages(probes: Vec<Probe>, message_max_bytes: usize) -> Vec<String>
         // Format probe
         let probe_str = encode_probe(&probe);
         // Max message size is 1048576 bytes
-        if current_message.len() + probe_str.len() + 1 > message_max_bytes {
+        if current_message.len() + probe_str.len() > message_max_bytes {
             // Remove the last newline character
             current_message.pop();
             messages.push(current_message);