Kafka 幂等性

发表于 分类于 阅读次数：

producer的幂等性是指 消息发送到broker，只会在broker被持久化一次，不丢不重

kafka原生机制只能保证在同一个会话的同一个topic下的同一个partition下保证不重

PS：同一个会话是指

Producer 启动 → 和 Broker 建立连接 → 发送消息 → 关闭（或挂掉）。

如果这时候宕机后重启，是否无法保证新消息与旧消息的唯一性的

原理

:::color4
producer会在内存维护一个seqNum，broker端会针对一个producor维护一个 lastSeq

如果msg > seqNumseq，则判断不重

:::