fix: Set kafka max message size in client
@@ -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()?;
