KTableSource — ProcessorSupplier of KTableSourceProcessors

KTableSource is created when InternalStreamsBuilder is requested to add a KTable and a GlobalKTable to a topology (when StreamsBuilder is requested to create a KTable and GlobalKTable for topics, respectively).

KTableSource takes a store name when created.

KTableSource creates a new KTableSourceProcessor whenever requested to supply one.

results matching ""

    No results matching ""