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

map

inline fun <inK, inV, outK, outV> KStream<inK, inV>.map(name: String, crossinline mapper: (key: inK, value: inV) -> Pair<outK, outV>): KStream<outK, outV>

See also