kafka幂等生成器能用多个分区确保精确一次吗

Question

我只是一个Kafka的新手，对Kafka生产者的幂等性学了一点知识。

根据我的理解，当生产者向代理发送消息时，代理需要向生产者发回一个ACK来告诉它消息已经收到。如果生产者由于某种原因没有接收到ACK，生产者必须再次向代理发送相同的消息，以便复制该消息。而幂等生成器可以消除这个问题。

基本上，每个生产者将被分配一个PID，每个消息将被分配一个序列号。所以PID+序列号可以识别一条消息。Kafka的理想化就是这样运作的。

null

Answer 1

在某个时刻，生成器正在向分区a发送消息X，a成功地接收到X，但在发送ACK时失败。因此生产者重新发送消息X。

它将是分区a或分区b，哪个将接收最新的消息X？

重新发送是在内部完成的，我们不在应用程序代码中完成。因此，当发送到分区a的消息X没有收到确认时，它将被重新发送到同一个分区。如果我们手动对应用程序代码进行重发，那么是的，会有重复的。