Как сделать consumer идемпотентным при семантике at-least-once?

Почему нужно: сообщение может прийти повторно после сбоя потребителя, ребаланса, повтора продюсера. «Прибавить 100 рублей» дважды — уже ошибка.

Способы:

• дедупликация по id — каждое событие несёт уникальный event_id. Обработчик в одной транзакции вставляет id в таблицу обработанных (уникальный ключ) и делает изменение. Повтор упадёт на уникальности — пропускаем. Записи хранят ограниченное время;
• естественная идемпотентность — операции, повтор которых ничего не меняет: UPSERT по ключу, «установить статус оплачен», «записать последнее значение»;
• версии — применять событие, только если его версия больше сохранённой для агрегата (заодно защищает от перестановок);
• внешние вызовы — передавать ключ идемпотентности во внешний API (платёжный провайдер не спишет дважды).

Важная деталь: проверка и эффект — атомарно. «Проверить в Redis, потом записать в базу» — гонка и окно для дубля при падении между шагами.

BEGIN;
INSERT INTO processed_events(event_id) VALUES ($1);   -- дубль упадёт здесь
UPDATE accounts SET balance = balance + $2 WHERE id = $3;
COMMIT;