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

forEach

fun <K, V> KStream<K, V>.forEach(name: String? = null, forEachAction: ForeachAction<K, V>)

See also