Skip to content

Commit

Permalink
fix seâratpr
Browse files Browse the repository at this point in the history
  • Loading branch information
SamuelQuetin committed Dec 12, 2023
1 parent 2246d36 commit d3423f7
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main/java/fr/abes/bestppn/kafka/TopicConsumer.java
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ public void kbartFromkafkaListener(ConsumerRecord<String, String> lignesKbart) {
try {
this.nbActiveThreads.incrementAndGet();
this.nbLignesTraitees.incrementAndGet();
ThreadContext.put("package", (filename + "[line : " + nbLignesTraitees.get() + "]")); //Ajoute le nom de fichier dans le contexte du thread pour log4j
ThreadContext.put("package", (filename + ";" + nbLignesTraitees.get())); //Ajoute le nom de fichier dans le contexte du thread pour log4j
service.processConsumerRecord(ligneKbartDto, providerName, isForced);
Header lastHeader = lignesKbart.headers().lastHeader("nbLinesTotal");
if (lastHeader != null) {
Expand Down

0 comments on commit d3423f7

Please sign in to comment.