apache-kafka - 如何让每条消息在 kafka 中都是持久的

Question

设置 log.flush.interval.messages=1。刷新是异步的还是同步的？这样，当producer client得到ack后，就说明这个消息是durable还是不持久的呢？

Answer 1

您可能必须编辑文件夹中的Producer属性文件Config。将其设置request.required.acks为-1使生产者持久，并确保在用户确认收到的消息之前消息不会丢失。

您可以查看此（在 Producer Configs 下）以获取更多参考。