fix: Increase kafka message size
@@ -77,8 +77,8 @@ impl KafkaBufferProducer {
let mut cfg = ClientConfig::new();
cfg.set("bootstrap.servers", &conn);
cfg.set("message.timeout.ms", "5000");
- cfg.set("message.max.bytes", "10000000");
- cfg.set("queue.buffering.max.kbytes", "10485760");
+ cfg.set("message.max.bytes", "31457280");
+ cfg.set("queue.buffering.max.kbytes", "31457280");
cfg.set("request.required.acks", "all"); // equivalent to acks=-1
let producer: FutureProducer = cfg.create()?;
