docs: Update write_buffer/src/kafka.rs

Co-authored-by: Edd Robinson <me@edd.io>
2021-07-16 17:53:02 +02:00 · 2021-07-16 17:53:02 +02:00 · de0dce79f6
parent 92623b5f32
commit de0dce79f6
1 changed files with 1 additions and 1 deletions
--- a/write_buffer/src/kafka.rs
+++ b/write_buffer/src/kafka.rs
@ -76,7 +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");
+        cfg.set("request.required.acks", "all");  // equivalent to acks=-1

        let producer: FutureProducer = cfg.create()?;