Downgrading kotlin-kafka to 3.1.0

navikt · Jan 10, 2025 · c6ddcb6 · c6ddcb6
1 parent 93e8452
commit c6ddcb6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/ebms-provider/src/main/kotlin/no/nav/emottak/ebms/App.kt b/ebms-provider/src/main/kotlin/no/nav/emottak/ebms/App.kt
@@ -29,7 +29,6 @@ import io.micrometer.prometheus.PrometheusConfig
 import io.micrometer.prometheus.PrometheusMeterRegistry
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.awaitCancellation
-import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.flow.onEach
 import kotlinx.coroutines.launch
 import net.logstash.logback.marker.Markers
@@ -108,8 +107,8 @@ suspend fun startSignalReceiver(kafka: Kafka) {
         .receive(kafka.incomingSignalTopic)
         .onEach { record ->
             signalProcessor.processSignal(record.key(), record.value())
+            record.offset.acknowledge()
         }
-        .collect()
 }
 
 fun Application.ebmsProviderModule(

diff --git a/settings.gradle.kts b/settings.gradle.kts
@@ -20,7 +20,7 @@ dependencyResolutionManagement {
             version("cxf", "3.5.5")
             version("arrow", "1.2.4")
             version("suspendapp", "0.4.0")
-            version("kotlin-kafka", "0.4.0")
+            version("kotlin-kafka", "0.3.1")
             version("hoplite", "2.8.2")
 
             library("bcpkix-jdk18on", "org.bouncycastle", "bcpkix-jdk18on").versionRef("bouncycastle")