KTableSource — ProcessorSupplier of KTableSourceProcessors
KTableSource
is a 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.