La til component1/2 extension på streams Record

navikt · Sep 19, 2024 · 8853dd8 · 8853dd8
1 parent 08badc2
commit 8853dd8
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/lib/kafka-streams/src/main/kotlin/no/nav/paw/config/kafka/streams/KafkaStreamsExtensions.kt b/lib/kafka-streams/src/main/kotlin/no/nav/paw/config/kafka/streams/KafkaStreamsExtensions.kt
@@ -0,0 +1,7 @@
+package no.nav.paw.config.kafka.streams
+
+import org.apache.kafka.streams.processor.api.Record
+
+
+operator fun <K, V> Record<K, V>.component1(): K = key()
+operator fun <K, V> Record<K, V>.component2(): V = value()