Updated Spring

Co-authored-by: Øyvind Norsted Wedøe <[email protected]>
navikt · Aug 31, 2022 · e75af37 · e75af37
1 parent 617d1c2
commit e75af37
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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