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

flatMap

inline fun <inK, inV, outK, outV> KStream<inK, inV>.flatMap(name: String? = null, crossinline mapper: (key: inK, value: inV) -> Iterable<Pair<outK, outV>>): KStream<outK, outV>

See also