diff --git a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
index b948994..79e50f2 100644
--- a/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
+++ b/src/main/java/fr/abes/logskbart/kafka/LogsListener.java
@@ -47,7 +47,7 @@ public LogsListener(ObjectMapper mapper, UtilsMapper logsMapper, LogKbartReposit
      * @param message le message kafka
      * @throws IOException exception levée
      */
-    @KafkaListener(topics = {"${topic.name.source.error}", "${topic.name.source.info}"}, groupId = "${topic.groupid.source}", containerFactory = "kafkaLogsListenerContainerFactory")
+    @KafkaListener(topics = {"${topic.name.source.error}"}, groupId = "${topic.groupid.source}", containerFactory = "kafkaLogsListenerContainerFactory")
     public void listenInfoKbart2KafkaAndErrorKbart2Kafka(ConsumerRecord<String, String> message) throws IOException {
         LogKbartDto dto = mapper.readValue(message.value(), LogKbartDto.class);
         LogKbart logKbart = logsMapper.map(dto, LogKbart.class);
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index 3ad0a3c..fbf49b5 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -20,8 +20,7 @@ spring.kafka.consumer.value-serializer=org.apache.kafka.common.serialization.Str
 spring.kafka.consumer.max-poll-records=10000
 
 # Topic Kafka
-topic.name.source.error=errorkbart2kafka
-topic.name.source.info=infokbart2kafka
+topic.name.source.error=bacon.logs.toload
 # Pour la partie consumer : insertion dans kafka de la ligne kbart avec bestppn
 
 spring.jpa.open-in-view=false