kotka-streams-extensions/dev.adamko.kotka.extensions.tables/toStream

toStream

fun <inK, V, outK> KTable<inK, V>.toStream(name: String, mapper: KeyValueMapper<inK, V, outK>? = null): KStream<outK, V?>
fun <K, V> KTable<K, V>.toStream(name: String): KStream<K, V?>

See also