fix: Set acks=all for kafka writes
@@ -76,6 +76,7 @@ impl KafkaBufferProducer {
cfg.set("message.timeout.ms", "5000");
cfg.set("message.max.bytes", "10000000");
cfg.set("queue.buffering.max.kbytes", "10485760");
+ cfg.set("request.required.acks", "all");
let producer: FutureProducer = cfg.create()?;
