From b96010133f9dbb635f5b4210d01004349a4b6291 Mon Sep 17 00:00:00 2001
From: "adel.ka" <a.kalimullin@micord.ru>
Date: Fri, 31 Oct 2025 16:52:52 +0300
Subject: [PATCH] SUPPORT-9528: add messageId

---
 .../audit/service/impl/BaseAuditKafkaPublisher.java   | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/backend/src/main/java/ru/micord/ervu/audit/service/impl/BaseAuditKafkaPublisher.java b/backend/src/main/java/ru/micord/ervu/audit/service/impl/BaseAuditKafkaPublisher.java
index 801667f7..4e99fc69 100644
--- a/backend/src/main/java/ru/micord/ervu/audit/service/impl/BaseAuditKafkaPublisher.java
+++ b/backend/src/main/java/ru/micord/ervu/audit/service/impl/BaseAuditKafkaPublisher.java
@@ -1,6 +1,10 @@
 package ru.micord.ervu.audit.service.impl;
 
 
+import java.nio.charset.StandardCharsets;
+import java.util.UUID;
+
+import org.apache.kafka.clients.producer.ProducerRecord;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Qualifier;
@@ -26,7 +30,12 @@ public class BaseAuditKafkaPublisher implements AuditKafkaPublisher {
 
   @Override
   public void publishEvent(String topic, String message) {
-    kafkaTemplate.send(topic, message)
+    String messageId = UUID.randomUUID().toString();
+    ProducerRecord<String, String> record = new ProducerRecord<>(topic, message);
+    record.headers()
+        .add("messageId", messageId.getBytes(StandardCharsets.UTF_8));
+
+    kafkaTemplate.send(record)
         .addCallback(
             result -> {
             },