StreamSourceNode¶

StreamSourceNode<K, V> is a SourceGraphNode.

Creating Instance¶

StreamSourceNode takes the following to be created:

• Node Name
• Topic Names or Pattern
• ConsumedInternal<K, V>

StreamSourceNode is created when:

• InternalStreamsBuilder is requested to stream
• KTableImpl is requested to doJoinOnForeignKey

writeToTopology¶

void writeToTopology(
  InternalTopologyBuilder topologyBuilder, 
  Properties props)

writeToTopology requests the given InternalTopologyBuilder to addSource.

writeToTopology is part of the GraphNode abstraction.