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

stream

fun <K, V> StreamsBuilder.stream(consumed: Consumed<K, V>? = null, vararg topics: String): KStream<K, V>
fun <K, V> StreamsBuilder.stream(vararg topics: String): KStream<K, V>

See also