kafka在高併發的狀況下,如何避免消息丟失和消息重複?

1.爲何會發生消息丟失和消息重複？ 消息發送 Kafka消息發送有兩種方式：同步（sync）和異步（async），默認是同步方式，可經過producer.type屬性進行配置。Kafka經過配置request.required.acks屬性來確認消息的生產： 0—表示不進行消息接收是否成功的確認； 1—表示當Leader接收成功時確認； -1—表示Leader和Follower都接收成功時確認；w

>>阅读原文<<