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 0a23a8d1d72256fb6312671b2ead4b4d6a1dd5bd..fb232c33e77dc44842cde45f1de3ceb59bdf0f12 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 40b010e0fc89fb3667e81ec8ec1411a38e1abd50..7763873ff51f5ee339a500229e5693e99b594e45 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