Идемпотентный producer (enable.idempotence=true) добавляет PID и sequence numbers, брокер дедуплицирует ретраи — exactly-once на уровне сессии записи в партицию (без дублей от retry).
Разбор
- Требует
acks=all и ограниченные retries/compat настройки.
- Не заменяет идемпотентность бизнес-операций консьюмера.
- Связан с transactions для EOS across partitions.
- Защищает от дублей при сетевых ретраях продюсера.
Итог
Idempotent producer убирает дубли ретраев записи на брокер.
