From 03524314c57bd9dda4a792067e2a4c7563c94a32 Mon Sep 17 00:00:00 2001
From: EryneKL <97091460+EryneKL@users.noreply.github.com>
Date: Tue, 6 Feb 2024 14:11:24 +0100
Subject: [PATCH 1/2] FEAT :
 CDE-348-rapport-derreur-bad-limiter-aux-erreurs-bloquantes :      -
 changement des log.error en log.warn pour les erreurs non bloquantes.      -
 changement du topic de destination pour les log.info et log.warn      - ajout
 d'un topic de destination pour les log.warn

---
 .../java/fr/abes/kbart2kafka/service/FileService.java    | 6 ++----
 src/main/resources/log4j2-all.xml                        | 9 +++++++--
 2 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/src/main/java/fr/abes/kbart2kafka/service/FileService.java b/src/main/java/fr/abes/kbart2kafka/service/FileService.java
index 3e3fe96..40deb19 100644
--- a/src/main/java/fr/abes/kbart2kafka/service/FileService.java
+++ b/src/main/java/fr/abes/kbart2kafka/service/FileService.java
@@ -18,7 +18,6 @@
 import java.io.File;
 import java.io.FileReader;
 import java.io.IOException;
-import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Random;
@@ -90,8 +89,7 @@ private void executeMultiThread(File fichier, String kbartHeader) throws IOExcep
                             assert result != null;
                             result.whenComplete((sr, ex) -> {
                                 try {
-//                                    log.debug("Message envoyé : {}", mapper.writeValueAsString(result.get().getProducerRecord().value()));
-                                    mapper.writeValueAsString(result.get().getProducerRecord().value());
+                                    log.debug(mapper.writeValueAsString(result.get().getProducerRecord().value())); // vérification du résultat de la transaction et log
                                 } catch (JsonProcessingException | InterruptedException | ExecutionException e) {
                                     log.warn("Erreur dans le mapping du résultat de l'envoi dans le topic pour la ligne " + ligneKbartDto);
                                 }
@@ -112,7 +110,7 @@ private void executeMultiThread(File fichier, String kbartHeader) throws IOExcep
     }
 
     private void sendErrorToKafka(String errorMessage, Exception exception, String filename) {
-        log.debug("Envoi erreur");
+        log.error(errorMessage + exception + " - " + filename);
         kafkaTemplate.send(new ProducerRecord<>(topicErrors, new Random().nextInt(nbThread), filename, errorMessage + exception.getMessage()));
     }
 
diff --git a/src/main/resources/log4j2-all.xml b/src/main/resources/log4j2-all.xml
index 0113a5c..c174159 100644
--- a/src/main/resources/log4j2-all.xml
+++ b/src/main/resources/log4j2-all.xml
@@ -17,16 +17,21 @@
     </Properties>
     <Appenders>
         <!-- KAFKA -->
-        <Kafka name="kafkaErrorLogAppender" topic="errorkbart2kafka" key="${ctx:package}">
+        <Kafka name="kafkaErrorLogAppender" topic="bacon.logs.toload" key="${ctx:package}">
             <JSONLayout />
             <Property name="bootstrap.servers">${kafkaServer}</Property>
             <LevelRangeFilter minLevel="ERROR" maxLevel="ERROR" onMatch="ACCEPT" onMismatch="DENY"/>
         </Kafka>
-        <Kafka name="kafkaInfoLogAppender" topic="infokbart2kafka" key="${ctx:package}">
+        <Kafka name="kafkaInfoLogAppender" topic="bacon.logs.toload" key="${ctx:package}">
             <JSONLayout />
             <Property name="bootstrap.servers">${kafkaServer}</Property>
             <LevelRangeFilter minLevel="INFO" maxLevel="INFO" onMatch="ACCEPT" onMismatch="DENY"/>
         </Kafka>
+        <Kafka name="kafkaInfoLogAppender" topic="bacon.logs.toload" key="${ctx:package}">
+            <JSONLayout />
+            <Property name="bootstrap.servers">${kafkaServer}</Property>
+            <LevelRangeFilter minLevel="WARN" maxLevel="WARN" onMatch="ACCEPT" onMismatch="DENY"/>
+        </Kafka>
         <!-- CONSOLE -->
         <Console name="Console">
             <PatternLayout

From 5638737b682e335980ddf70e472a21d3fbe9b12e Mon Sep 17 00:00:00 2001
From: EryneKL <97091460+EryneKL@users.noreply.github.com>
Date: Wed, 7 Feb 2024 10:45:46 +0100
Subject: [PATCH 2/2] FEAT :
 CDE-348-rapport-derreur-bad-limiter-aux-erreurs-bloquantes :      -
 changement des log.error en log.warn pour les erreurs non bloquantes.      -
 changement du topic de destination pour les log.info et log.warn      - ajout
 d'un topic de destination pour les log.warn

---
 src/main/resources/log4j2-all.xml | 13 ++-----------
 1 file changed, 2 insertions(+), 11 deletions(-)

diff --git a/src/main/resources/log4j2-all.xml b/src/main/resources/log4j2-all.xml
index c174159..e3f3541 100644
--- a/src/main/resources/log4j2-all.xml
+++ b/src/main/resources/log4j2-all.xml
@@ -17,20 +17,11 @@
     </Properties>
     <Appenders>
         <!-- KAFKA -->
+        <!--    Les levels d'erreurs pris en compte sont INFO, WARN et ERROR    -->
         <Kafka name="kafkaErrorLogAppender" topic="bacon.logs.toload" key="${ctx:package}">
             <JSONLayout />
             <Property name="bootstrap.servers">${kafkaServer}</Property>
-            <LevelRangeFilter minLevel="ERROR" maxLevel="ERROR" onMatch="ACCEPT" onMismatch="DENY"/>
-        </Kafka>
-        <Kafka name="kafkaInfoLogAppender" topic="bacon.logs.toload" key="${ctx:package}">
-            <JSONLayout />
-            <Property name="bootstrap.servers">${kafkaServer}</Property>
-            <LevelRangeFilter minLevel="INFO" maxLevel="INFO" onMatch="ACCEPT" onMismatch="DENY"/>
-        </Kafka>
-        <Kafka name="kafkaInfoLogAppender" topic="bacon.logs.toload" key="${ctx:package}">
-            <JSONLayout />
-            <Property name="bootstrap.servers">${kafkaServer}</Property>
-            <LevelRangeFilter minLevel="WARN" maxLevel="WARN" onMatch="ACCEPT" onMismatch="DENY"/>
+            <LevelRangeFilter minLevel="INFO" maxLevel="ERROR" onMatch="ACCEPT" onMismatch="DENY"/>
         </Kafka>
         <!-- CONSOLE -->
         <Console name="Console">