Skip to content


Creating Instance

Command takes the following to be created:

  • Statement Text
  • Overwrite Properties (Map<String, Object>)
  • Original Properties (Map<String, String>)
  • KsqlPlan
  • Version
  • Expected Version

Command is created using of utilities and when:

  • RestoreCommandsCompactor is requested to compact


Command can be given a KsqlPlan when created (using of utility that accepts a ConfiguredKsqlPlan).

Creating Command

Command of(
  ConfiguredKsqlPlan configuredPlan)
Command of(
  ConfiguredStatement<?> configuredStatement)

of creates a Command.

of (with a ConfiguredKsqlPlan) is used when:

of (with a ConfiguredStatement) is used when: