Skip to content


KsqlStream is a StructuredDataSource with KSTREAM type.

Creating Instance

KsqlStream takes the following to be created:

  • SQL expression
  • Source name
  • LogicalSchema
  • TimestampColumn
  • isKsqlSink flag
  • KsqlTopic
  • isSourceStream flag

KsqlStream is created when:


DataSource with(
  String sql,
  LogicalSchema schema)

with is part of the DataSource abstraction.

with creates a new copy of this KsqlStream with the following changes: