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

groupBy

fun <inK, inV, outK, outV> KTable<inK, inV>.groupBy(grouped: Grouped<outK, outV>? = null, selector: KeyValueMapper<inK, inV, KeyValue<outK, outV>>): KGroupedTable<outK, outV>

See also