Property Detail

• static final java.lang.String ANALYTICS_NAME

• @org.gradle.api.tasks.Input @org.gradle.api.tasks.options.Option(option = "from-beginning", description = "When defined, set 'ksql.streams.auto.offset.reset' to 'earliest'." ) boolean fromBeginning

  When defined, then set "ksql.streams.auto.offset.reset" to "earliest".

• @org.gradle.api.tasks.Input @org.gradle.api.tasks.options.Option(option = 'no-create', description = 'When defined, CREATE statements in KSQL scripts are not executed. Used primarily for auto-generating and executing applicable DROP and/or TERMINATE statements.' ) boolean noCreate

  When defined, CREATE statements found in KSQL scripts are not executed. Used primarily for auto-generating and executing applicable DROP and/or TERMINATE statements.

• @org.gradle.api.tasks.Input @org.gradle.api.tasks.options.Option(option = 'no-drop', description = 'When defined, applicable DROP statements are not auto-generated and executed.' ) boolean noDrop

  When defined, applicable DROP statements are not auto-generated and executed.

• @org.gradle.api.tasks.Input @org.gradle.api.tasks.options.Option(option = 'no-terminate', description = 'When defined, applicable TERMINATE statements are not auto-generated and executed.' ) boolean noTerminate

  When defined, applicable TERMINATE statements are not auto-generated and executed.

• @org.gradle.api.tasks.Input @java.util.Optional @org.gradle.api.tasks.options.Option(option = "basic-password", description = "The Password for Basic Authentication with the REST API URL for the KSQL Server. Default: value of 'confluent.pipelinePassword' or ''." ) java.lang.String password

  The Password for Basic Authentication with the REST API URL for the KSQL Server. Default: the extension property com.redpillanalytics.gradle.ConfluentPluginExtensions#pipelinePassword.

• @org.gradle.api.tasks.Input @org.gradle.api.tasks.options.Option(option = "rest-url", description = "The REST API URL for the KSQL Server. Default: value of 'confluent.pipelineEndpoint' or 'http://localhost:8088'." ) java.lang.String restUrl

  The REST API URL for the KSQL Server. Default: the extension property ConfluentPluginExtension.pipelineEndpoint.

• @org.gradle.api.tasks.Input @java.util.Optional @org.gradle.api.tasks.options.Option(option = "basic-username", description = "The Username for Basic Authentication with the REST API URL for the KSQL Server. Default: value of 'confluent.pipelineUsername' or ''." ) java.lang.String username

  The Username for Basic Authentication with the REST API URL for the KSQL Server. Default: the extension property com.redpillanalytics.gradle.ConfluentPluginExtensions#pipelineUsername.

Constructor Detail

• PipelineExecuteTask()

Method Detail

• @org.gradle.api.tasks.TaskAction java.lang.Object executePipelines()

• @org.gradle.api.tasks.Internal java.lang.Object getKsqlRest()

  Instantiates a KsqlRest Class, which is used for interacting with the KSQL RESTful API.

  Returns:

  KsqlRest