micord/ervu-lkrp-ul
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-9528: add messageId

Browse source
This commit is contained in:
adel.ka 2025-10-31 16:52:52 +03:00
parent d106b37d8e
commit b96010133f
1 changed files with 10 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

11
backend/src/main/java/ru/micord/ervu/audit/service/impl/BaseAuditKafkaPublisher.java
View file

@ -1,6 +1,10 @@
package ru.micord.ervu.audit.service.impl; 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.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
@ -26,7 +30,12 @@ public class BaseAuditKafkaPublisher implements AuditKafkaPublisher {
@Override @Override
public void publishEvent(String topic, String message) { 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( .addCallback(
result -> { result -> {
}, },