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 new file mode 100644 index 00000000..4e46295f --- /dev/null +++ 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 Record.component1(): K = key() +operator fun Record.component2(): V = value()