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

toTable

fun <K, V> KStream<K, V>.toTable(name: String? = null, materialized: Materialized<K, V, KeyValueStore<Bytes, ByteArray>>? = null): KTable<K, V>

See also