diff --git a/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java b/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java index 9e337af..863b258 100644 --- a/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java +++ b/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java @@ -17,6 +17,7 @@ import fr.abes.kafkatosudoc.service.EmailService; import fr.abes.kafkatosudoc.service.SudocService; import fr.abes.kafkatosudoc.utils.CheckFiles; +import fr.abes.kafkatosudoc.utils.Utils; import fr.abes.kafkatosudoc.utils.UtilsMapper; import lombok.extern.slf4j.Slf4j; import org.apache.avro.generic.GenericRecord; @@ -382,7 +383,10 @@ public void listenKbartFromKafkaExNihilo(ConsumerRecord