男孩做网站,设计师互动平台,郑州网站设计报价表,同城购物网站建设1. 生产者开启幂等性为什么能去重#xff1f;
1.1 场景
适用于消息在写入到服务器日志后#xff0c;由于网络故障#xff0c;生产者没有及时收到服务端的ACK消息#xff0c;生产者误以为消息没有持久化到服务端#xff0c;导致生产者重复发送该消息#xff0c;造成了消…1. 生产者开启幂等性为什么能去重
1.1 场景
适用于消息在写入到服务器日志后由于网络故障生产者没有及时收到服务端的ACK消息生产者误以为消息没有持久化到服务端导致生产者重复发送该消息造成了消息的重复现象而幂等性就是为了解决该问题。 1.2 去重原理
通过3个值的唯一性去重
PID生产者ID分区号seq单调递增 2. 生产者开启事务为什么能去重
2.1 场景
当数据发送到broker时失败了导致ack没有应答成功如果没有开启事务那么这条数据可能只落在了leader的磁盘上没有落在flower的磁盘上此时会进行重试再把数据发送一遍那么leader的数据就重复了。
2.2 去重原理
如果开启事务那就会有原子性数据要么写成功落盘要么写失败回滚。
当数据发送到broker时失败了导致ack应答失败这条数据可能只落在了leader的磁盘上没有落在flower的磁盘上如果开启了事务那么会进行回滚将leader的数据回滚然后会进行重试再把数据发送一遍就解决了重复问题。
