From c280bd32ba8410be47f56dc5ef64f7a6e4621b80 Mon Sep 17 00:00:00 2001
From: EryneKL <97091460+EryneKL@users.noreply.github.com>
Date: Wed, 7 Feb 2024 10:05:13 +0100
Subject: [PATCH] FEAT :
 CDE-348-rapport-derreur-bad-limiter-aux-erreurs-bloquantes      - unification
 des deux topics de logs (INFO et ERROR) en un seul topic

---
 src/main/java/fr/abes/logskbart/kafka/LogsListener.java | 2 +-
 src/main/resources/application.properties               | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)

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