Как да предотвратим повторната обработка на същото съобщение Kafka? Къде и как да организираме проверка за идемпотентност от страна на потребителя?