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

mapValues

fun <K, inV, outV> KStream<K, inV>.mapValues(name: String, mapper: (key: K, value: inV) -> outV): KStream<K, outV>

See also