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

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

StreamSourceNode takes the following when created:

writeToTopology Method

void writeToTopology(final InternalTopologyBuilder topologyBuilder)
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 ""