fix: Set kafka max message size in client

write_buffer/src/kafka.rs

@@ -68,6 +68,7 @@ impl KafkaBufferProducer {
         let mut cfg = ClientConfig::new();
         cfg.set("bootstrap.servers", &conn);
         cfg.set("message.timeout.ms", "5000");
+        cfg.set("message.max.bytes", "10000000");
 
         let producer: FutureProducer = cfg.create()?;