kotka-streams-extensions/dev.adamko.kotka.extensions.streams/branch

branch

fun <K, V> BranchedKStream<K, V>.branch(branched: Branched<K, V>, predicate: Predicate<K, V>): BranchedKStream<K, V>

See also