У тебя Kafka consumer, который пишет события в БД. Иногда после обработки и до commit'а offset'а worker падает. После рестарта то же сообщение приходит снова — получаем дубль в БД. Как сделать consumer идемпотентным?