From 2bae424d383e059be6283723f2de385757800190 Mon Sep 17 00:00:00 2001
From: LEMERCIER Denis <denis.lemercier@soprasteria.com>
Date: Thu, 23 Jan 2025 14:52:10 +0000
Subject: [PATCH] correction du backoff en seconde
---
.../calculs/infrastructure/config/KafkaConfiguration.java | 2 +-
services/api-event-calculs/src/main/resources/application.yaml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/services/api-event-calculs/src/main/java/org/mte/numecoeval/calculs/infrastructure/config/KafkaConfiguration.java b/services/api-event-calculs/src/main/java/org/mte/numecoeval/calculs/infrastructure/config/KafkaConfiguration.java
index 0a23a8d1..fb232c33 100644
--- a/services/api-event-calculs/src/main/java/org/mte/numecoeval/calculs/infrastructure/config/KafkaConfiguration.java
+++ b/services/api-event-calculs/src/main/java/org/mte/numecoeval/calculs/infrastructure/config/KafkaConfiguration.java
@@ -18,7 +18,7 @@ public class KafkaConfiguration {
DefaultErrorHandler defaultErrorHandler() {
return new DefaultErrorHandler(
(rec, ex) -> log.error("Erreur kafka: {}", rec, ex),
- new FixedBackOff(Long.parseLong(backOffSec), Integer.MAX_VALUE)
+ new FixedBackOff(Long.parseLong(backOffSec) * 1000, Integer.MAX_VALUE)
);
}
diff --git a/services/api-event-calculs/src/main/resources/application.yaml b/services/api-event-calculs/src/main/resources/application.yaml
index 40b010e0..7763873f 100644
--- a/services/api-event-calculs/src/main/resources/application.yaml
+++ b/services/api-event-calculs/src/main/resources/application.yaml
@@ -16,7 +16,7 @@ spring:
# Kafka
kafka:
bootstrap-servers: localhost:9092
- back-off-sec: 30000
+ back-off-sec: 30
consumer:
group-id: api-event-calculs
auto-offset-reset: earliest
--
GitLab