bumper tbd-libs

Author: davidsteinsland

build.gradle.kts

@@ -8,7 +8,7 @@ val logbackClassicVersion = "1.5.18"
 val logbackEncoderVersion = "8.0"
 val awaitilityVersion = "4.2.2"
 val kafkaTestcontainerVersion = "1.20.6"
-val tbdLibsVersion = "2025.05.26-17.37-02cf81b0"
+val tbdLibsVersion = "2025.05.27-09.58-a0d8bd0d"
 
 group = "com.github.navikt"
 version = properties["version"] ?: "local-build"

src/main/kotlin/no/nav/helse/rapids_rivers/RapidApplication.kt

@@ -5,10 +5,12 @@ import com.github.navikt.tbd_libs.kafka.ConsumerProducerFactory
 import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.KafkaRapid
 import com.github.navikt.tbd_libs.rapids_and_rivers.createDefaultKafkaRapidFromEnv
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.FailedMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.OutgoingMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.SentMessage
 import io.ktor.server.application.*
 import io.ktor.server.cio.*
 import io.ktor.server.engine.*
@@ -76,8 +78,8 @@ class RapidApplication internal constructor(
         rapid.publish(key, message)
     }
 
-    override fun publishBulk(messages: List<OutgoingMessage>) {
-        rapid.publishBulk(messages)
+    override fun publish(messages: List<OutgoingMessage>): Pair<List<SentMessage>, List<FailedMessage>> {
+        return rapid.publish(messages)
     }
 
     override fun rapidName(): String {