From ef14e8214bc648ce50903927f6e0d3e091740775 Mon Sep 17 00:00:00 2001 From: SamuelQuetin Date: Tue, 19 Dec 2023 11:31:40 +0100 Subject: [PATCH] modif thread context --- src/main/java/fr/abes/kbart2kafka/service/FileService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/fr/abes/kbart2kafka/service/FileService.java b/src/main/java/fr/abes/kbart2kafka/service/FileService.java index f0b01e4..387d6ef 100644 --- a/src/main/java/fr/abes/kbart2kafka/service/FileService.java +++ b/src/main/java/fr/abes/kbart2kafka/service/FileService.java @@ -7,6 +7,7 @@ import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.common.header.internals.RecordHeader; +import org.apache.logging.log4j.ThreadContext; import org.springframework.beans.factory.annotation.Value; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.support.SendResult; @@ -70,8 +71,8 @@ private void executeMultiThread(File fichier, String kbartHeader) throws IOExcep List fileContent = buff.lines().toList(); Integer nbLignesFichier = fileContent.size() - 1; for (String ligneKbart : fileContent) { + lineCounter++; if (!ligneKbart.contains(kbartHeader)) { - lineCounter++; // Crée un nouvel objet dto, set les différentes parties et envoi au service topicProducer String[] tsvElementsOnOneLine = ligneKbart.split("\t"); LigneKbartDto ligneKbartDto = constructDto(tsvElementsOnOneLine); @@ -79,6 +80,7 @@ private void executeMultiThread(File fichier, String kbartHeader) throws IOExcep final int finalLineCounter = lineCounter; executor.execute(() -> { try { + ThreadContext.put("package", fichier.getName()); List headers = new ArrayList<>(); headers.add(new RecordHeader("FileName", fichier.getName().getBytes(StandardCharsets.UTF_8))); headers.add(new RecordHeader("nbCurrentLines", String.valueOf(finalLineCounter).getBytes()));