kafka在高并发的状况下,如何避免消息丢失和消息重复?

1.为何会发生消息丢失和消息重复？ 消息发送 Kafka消息发送有两种方式：同步（sync）和异步（async），默认是同步方式，可经过producer.type属性进行配置。Kafka经过配置request.required.acks属性来确认消息的生产： 0—表示不进行消息接收是否成功的确认； 1—表示当Leader接收成功时确认； -1—表示Leader和Follower都接收成功时确认；w

>>阅读原文<<