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