From e75af37f338e385f180c1f0f41a439a03119823c Mon Sep 17 00:00:00 2001 From: Andreas Jonsson Date: Wed, 31 Aug 2022 14:42:28 +0200 Subject: [PATCH] Updated Spring MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Øyvind Norsted Wedøe --- build.gradle.kts | 2 +- .../kotlin/no/nav/klage/config/AivenKafkaConfiguration.kt | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/build.gradle.kts b/build.gradle.kts index e826153..f1e28ef 100644 --- a/build.gradle.kts +++ b/build.gradle.kts @@ -24,7 +24,7 @@ repositories { plugins { id("org.jetbrains.kotlin.jvm") version "1.7.10" - id("org.springframework.boot") version "2.5.12" + id("org.springframework.boot") version "2.7.3" id("org.jetbrains.kotlin.plugin.spring") version "1.7.10" idea } diff --git a/src/main/kotlin/no/nav/klage/config/AivenKafkaConfiguration.kt b/src/main/kotlin/no/nav/klage/config/AivenKafkaConfiguration.kt index cb9cc77..cc00571 100644 --- a/src/main/kotlin/no/nav/klage/config/AivenKafkaConfiguration.kt +++ b/src/main/kotlin/no/nav/klage/config/AivenKafkaConfiguration.kt @@ -21,7 +21,7 @@ import org.springframework.kafka.core.DefaultKafkaConsumerFactory import org.springframework.kafka.core.DefaultKafkaProducerFactory import org.springframework.kafka.core.KafkaTemplate import org.springframework.kafka.listener.DeadLetterPublishingRecoverer -import org.springframework.kafka.listener.SeekToCurrentErrorHandler +import org.springframework.kafka.listener.DefaultErrorHandler import org.springframework.util.backoff.FixedBackOff import java.time.Duration @@ -61,13 +61,13 @@ class AivenKafkaConfiguration( r.partition() ) } - factory.setErrorHandler( - SeekToCurrentErrorHandler(recoverer, FixedBackOff(0L, 2L)) + factory.setCommonErrorHandler( + DefaultErrorHandler(recoverer, FixedBackOff(0L, 2L)) ) //Retry consumer/listener even if authorization fails at first factory.setContainerCustomizer { container -> - container.containerProperties.authorizationExceptionRetryInterval = Duration.ofSeconds(10L) + container.containerProperties.setAuthExceptionRetryInterval(Duration.ofSeconds(10L)) } return factory