Как обработать дублирующееся Kafka-событие при доставке at-least-once (хотя бы один раз)?
Для решения проблемы дублирования событий и несогласованности между базой данных и Kafka часто применяют паттерн "Идемпотентности" и транзакционную обработку.
Читать ответ