Как защититься от повторной обработки одного Kafka-сообщения? Где и как организовать проверку идемпотентности на consumer-стороне?
Чтобы избежать повторной отправки одинакового сообщения в Kafka, если статус исходного события не изменился, можно реализовать идемпотентность на уровне отправки сообщений. Вот несколько подходов:
Читать ответ