add left join

navikt · Apr 22, 2022 · 88c8b5c · 88c8b5c
1 parent a7ee688
commit 88c8b5c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/kafka/main/no/nav/aap/kafka/streams/KStreamExtensions.kt b/kafka/main/no/nav/aap/kafka/streams/KStreamExtensions.kt
@@ -8,6 +8,9 @@ private val secureLog = LoggerFactory.getLogger("secureLog")
 fun <K, V, VO, VR> KStream<K, V>.join(joined: Joined<K, V, VO>, table: KTable<K, VO>, joiner: (V, VO) -> VR) =
     join(table, joiner, joined)!!
 
+fun <K, V, VO, VR> KStream<K, V>.leftJoin(joined: Joined<K, V, VO>, table: KTable<K, VO>, joiner: (V, VO) -> VR) =
+    leftJoin(table, joiner, joined)!!
+
 /**
  * @param keyMapper: Map from a KStream record key to a GlobalKTable record key
  * @param table: GlobalKTable