Kafka 數據丟失和數據重複的原因和解決辦法

數據丟失的原因 Kafka 消息發送分同步 (sync)、異步 (async) 兩種方式，默認使用同步方式，可通過 producer.type 屬性進行配置； 通過 request.required.acks 屬性進行配置：值可設爲 0, 1, -1(all)    -1 和 all 等同 0 代表：不等待 broker 的 ack，這一操作提供了一個最低的延遲，broker 一接收到還沒有寫入磁

>>阅读原文<<