Skip to content


StreamSource is a SourceStep that builds a KStream (Kafka Streams).

Creating Instance

StreamSource takes the following to be created:

  • ExecutionStepPropertiesV1
  • Topic Name
  • Formats
  • TimestampColumn
  • LogicalSchema
  • Pseudo Column Version

StreamSource is created when:

Building KStreamHolder

KStreamHolder<GenericKey> build(
  PlanBuilder builder,
  PlanInfo info)

build requests the given PlanBuilder to visitStreamSource (with this StreamSource and the given PlanInfo).

build is part of the ExecutionStep abstraction.

Back to top