Skip to content

Latest commit

 

History

History
6 lines (4 loc) · 1.5 KB

kafka-streams-internals-ProcessorParameters.adoc

File metadata and controls

6 lines (4 loc) · 1.5 KB

ProcessorParameters

ProcessorParameters represents a ProcessorSupplier and a processor name to use to add a new processor (to InternalTopologyBuilder).

ProcessorParameters abstracts away different number of processors of StreamsGraphNodes (i.e. KTableKTableJoinNode, OptimizableRepartitionNode, ProcessorGraphNode, StatefulProcessorNode, StreamStreamJoinNode, StreamTableJoinNode, TableProcessorNode, and TableSourceNode) when requested to write to a topology (when InternalStreamsBuilder is requested to build a topology when StreamsBuilder is requested to build a topology).