Kafka idempotent producer

EN: Kafka idempotent producer

Kafka-producer с включённым enable.idempotence=true, получающий от брокера уникальный producer ID (PID) при запуске. Он добавляет к каждому батчу записей PID и монотонно возрастающий sequence number на каждую topic-partition. Брокер отклоняет батчи с уже зафиксированным sequence number, дедуплицируя повторные попытки в рамках одной сессии producer-а и гарантируя exactly-once-запись в каждой партиции.