Как защититься от дублирующихся сообщений в Kafka (идемпотентность)?