Каким образом избежать отправки одинакового сообщения в Kafka повторно, если статус исходного события не изменился?