Merge pull request #26 from abes-esr/CDE-348-rapport-derreur-bad-limi…

…ter-aux-erreurs-bloquantes FEAT : CDE-348-rapport-derreur-bad-limiter-aux-erreurs-bloquantes
abes-esr · Feb 7, 2024 · dd51b70 · dd51b70
2 parents b77449e + c280bd3
commit dd51b70
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git 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
@@ -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