Kafka生产者事务和幂等

1 生产者幂等性 1.1 引入 幂等性引入目的： 生产者重复生产消息。生产者进行retry会产生重试时，会重复产生消息。有了幂等性之后，在进行retry重试时，只会生成一个消息。 1.2 幂等性实现 1.2.1 PID 和 Sequence Number 为了实现Producer的幂等性，Kafka引入了Producer ID（即PID）和Sequence Number。 PID。每个新的Prod

>>阅读原文<<