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
index a25322a3..6614cb9c 100644
--- 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
index ca7fc0de..7ffe7737 100644
--- 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")