diff --git a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java index 1ac78bd..00fc9ad 100644 --- a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java +++ b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java @@ -18,6 +18,7 @@ import java.sql.Timestamp; import java.time.LocalDateTime; import java.time.ZoneId; +import java.util.Arrays; import java.util.Date; import java.util.Map; import java.util.concurrent.TimeUnit; @@ -57,7 +58,7 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord 1) ? listMessage[1] : ""; logKbart.setNbLine(Integer.parseInt((nbLineOrigine.isEmpty() ? "-1" : nbLineOrigine) )); -// logKbart.log(); + logKbart.log(); // VĂ©rifie qu'un fichier portant le nom du kbart en cours existe if (!logKbart.getPackageName().contains("ctx:package") && !logKbart.getPackageName().contains("_FORCE")) {