Instance

data class Instance<K, V>(val updatesKStream: KStream<K, V>, val globalKTable: GlobalKTable<K, V>, val definition: GlobalKTableDefinition<K, V>)

A GlobalKTable and the backing topic from which the table is filled.

Constructors

Link copied to clipboard
constructor(updatesKStream: KStream<K, V>, globalKTable: GlobalKTable<K, V>, definition: GlobalKTableDefinition<K, V>)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard