diff --git a/src/main/java/fr/abes/logskbart/kafka/KbartListener.java b/src/main/java/fr/abes/logskbart/kafka/KbartListener.java
deleted file mode 100644
index e69de29..0000000
diff --git a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
index 3b2c9b4..44d3a1a 100644
--- a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
+++ b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
@@ -42,7 +42,7 @@ public class LogsListener {
     @KafkaListener(topics = {"errorkbart2kafka", "bestppn.endoftraitment"}, groupId = "logskbart", containerFactory = "kafkaLogsListenerContainerFactory")
     public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, String> message) throws IOException {
 
-        if (!message.value().equals("OK")) {
+        if (message.topic().equals("errorkbart2kafka")) {
             Kbart2KafkaDto dto = mapper.readValue(message.value(), Kbart2KafkaDto.class);
             LogKbart entity = logsMapper.map(dto, LogKbart.class);
             Timestamp timestamp = new Timestamp(message.timestamp());
@@ -79,7 +79,7 @@ public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, Stri
             //  Inscrit l'entity en BDD
             repository.save(entity);
 
-        } else if (message.value().equals("OK")) {    //  Si la ligne sur le topic bestppn.endoftraitment contient OK
+        } else {    //  Si la ligne sur le topic bestppn.endoftraitment contient OK
 
             //  Créer un nouveau Path avec le FileName (en remplaçant l'extension par .err)
             Path source = null;