Refactor : renommage variables Kafka dans application.properties

abes-esr · Sep 2, 2024 · 6d048f0 · 6d048f0
1 parent f53bf36
commit 6d048f0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/fr/abes/kafkatosudoc/configuration/KafkaConfig.java b/src/main/java/fr/abes/kafkatosudoc/configuration/KafkaConfig.java
@@ -24,13 +24,13 @@
 @Configuration
 @EnableKafka
 public class KafkaConfig {
-    @Value("${spring.kafka.consumer.bootstrap-servers}")
+    @Value("${abes.kafka.bootstrap-servers}")
     private String bootstrapAddress;
 
     @Value("${spring.kafka.consumer.properties.isolation.level}")
     private String isolationLevel;
 
-    @Value("${spring.kafka.registry.url}")
+    @Value("${abes.kafka.registry.url}")
     private String registryUrl;
 
     @Bean

diff --git a/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java b/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java
@@ -77,7 +77,7 @@ public KbartListener(UtilsMapper mapper, BaconService baconService, EmailService
      *
      * @param lignesKbart : ligne trouvée dans kafka
      */
-    @KafkaListener(topics = {"${topic.name.source.kbart.toload}"}, groupId = "${topic.groupid.source.withppn}", containerFactory = "kafkaKbartListenerContainerFactory", concurrency = "${spring.kafka.concurrency.nbThread}")
+    @KafkaListener(topics = {"${topic.name.source.kbart.toload}"}, groupId = "${topic.groupid.source.withppn}", containerFactory = "kafkaKbartListenerContainerFactory", concurrency = "${abes.kafka.concurrency.nbThread}")
     public void listenKbartToCreateFromKafka(ConsumerRecord<String, LigneKbartConnect> lignesKbart) throws IOException {
         String filename = extractFilenameFromKey(lignesKbart.key());
         if (!this.workInProgressMap.containsKey(filename)) {