StreamSourceNode

StreamSourceNode is a StreamsGraphNode that is created when InternalStreamsBuilder is requested to add a KStream to a topology.

In other words, StreamSourceNode represents StreamsBuilder.stream and KStreamImpl.through operators.

StreamSourceNode takes the following when created:

writeToTopology Method

void writeToTopology(final InternalTopologyBuilder topologyBuilder)
Note
writeToTopology is part of the StreamsGraphNode Contract to…​FIXME.

writeToTopology simply requests the given InternalTopologyBuilder to addSource (per ConsumedInternal and topicPattern or topicNames).

results matching ""

    No results matching ""