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

groupBy

fun <K, V, outK> KStream<K, V>.groupBy(grouped: Grouped<outK, V>, keySelector: (K, V) -> outK): KGroupedStream<outK, V>

See also