Merge pull request #68 from abes-esr/develop

Merge develop dans main
abes-esr · Sep 2, 2024 · 4ddbe06 · 4ddbe06
2 parents 28f6209 + f53bf36
commit 4ddbe06
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 12 deletions.
diff --git a/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java b/src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java
@@ -79,7 +79,7 @@ public KbartListener(UtilsMapper mapper, BaconService baconService, EmailService
      */
     @KafkaListener(topics = {"${topic.name.source.kbart.toload}"}, groupId = "${topic.groupid.source.withppn}", containerFactory = "kafkaKbartListenerContainerFactory", concurrency = "${spring.kafka.concurrency.nbThread}")
     public void listenKbartToCreateFromKafka(ConsumerRecord<String, LigneKbartConnect> lignesKbart) throws IOException {
-        String filename = lignesKbart.key();
+        String filename = extractFilenameFromKey(lignesKbart.key());
         if (!this.workInProgressMap.containsKey(filename)) {
             this.workInProgressMap.put(filename, new WorkInProgress<>());
             lignesKbart.headers().forEach(header -> {
@@ -357,7 +357,7 @@ private void suppressionLien469(SudocService service, List<String> listError, in
     @KafkaListener(topics = {"${topic.name.source.kbart.exnihilo}"}, groupId = "${topic.groupid.source.exnihilo}", containerFactory = "kafkaKbartListenerContainerFactory")
     public void listenKbartFromKafkaExNihilo(ConsumerRecord<String, LigneKbartConnect> ligneKbart) {
         log.debug("Entrée dans création ex nihilo");
-        String filename = ligneKbart.key();
+        String filename = extractFilenameFromKey(ligneKbart.key());
 
         // S'il s'agit d'un premier message d'un fichier kbart, on créé un WorkInProgress avec le nom du fichier et le nombre total de ligne
         if (!this.workInProgressMapExNihilo.containsKey(filename)) {
@@ -437,7 +437,7 @@ private void creerNoticeExNihilo(LigneKbartConnect ligneKbartConnect, String pro
      */
     @KafkaListener(topics = {"${topic.name.source.kbart.imprime}"}, groupId = "${topic.groupid.source.imprime}", containerFactory = "kafkaKbartListenerContainerFactory")
     public void listenKbartFromKafkaImprime(ConsumerRecord<String, LigneKbartImprime> lignesKbart) {
-        String filename = lignesKbart.key();
+        String filename = extractFilenameFromKey(lignesKbart.key());
 
         // S'il s'agit d'un premier message d'un fichier kbart, on créé un WorkInProgress avec le nom du fichier et le nombre total de ligne
         if (!this.workInProgressMapImprime.containsKey(filename)) {
@@ -527,4 +527,8 @@ private NoticeConcrete creerNoticeAPartirImprime(LigneKbartImprime ligneKbartImp
             throw e;
         }
     }
+
+    private String extractFilenameFromKey (String key) {
+        return key.substring(0, key.lastIndexOf('_'));
+    }
 }
diff --git a/src/main/resources/application-dev.properties b/src/main/resources/application-dev.properties
@@ -1,7 +1,7 @@
 # Consumer properties
-spring.kafka.consumer.bootstrap-servers=
-spring.kafka.registry.url=
-spring.kafka.concurrency.nbThread=
+abes.kafka.bootstrap-servers=
+abes.kafka.registry.url=
+abes.kafka.concurrency.nbThread=
 
 #Connexion au sudoc
 sudoc.serveur=

diff --git a/src/main/resources/application-prod.properties b/src/main/resources/application-prod.properties
@@ -1,7 +1,7 @@
 # Consumer properties
-spring.kafka.consumer.bootstrap-servers=
-spring.kafka.registry.url=
-spring.kafka.concurrency.nbThread=
+abes.kafka.bootstrap-servers=
+abes.kafka.registry.url=
+abes.kafka.concurrency.nbThread=
 
 #Connexion au sudoc
 sudoc.serveur=

diff --git a/src/main/resources/application-test.properties b/src/main/resources/application-test.properties
@@ -1,7 +1,7 @@
 # Consumer properties
-spring.kafka.consumer.bootstrap-servers=
-spring.kafka.registry.url=
-spring.kafka.concurrency.nbThread=
+abes.kafka.bootstrap-servers=
+abes.kafka.registry.url=
+abes.kafka.concurrency.nbThread=
 
 #Connexion au sudoc
 sudoc.serveur=