Skip to content


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:


void writeToTopology(
  InternalTopologyBuilder topologyBuilder, 
  Properties props)

writeToTopology requests the given InternalTopologyBuilder to addSource.

writeToTopology is part of the GraphNode abstraction.

Back to top