Apache Kafka ConnectorRestart

Apache Kafka ConnectorRestart
Certified
Restart a Kafka Connect connector

By default restarts only the connector instance itself, leaving its tasks untouched. Set includeTasks: true to also restart its tasks, and onlyFailed: true to restrict the restart to failed tasks only.

yaml
type: io.kestra.plugin.kafka.ConnectorRestart

Examples

Restart only the failed tasks of a connector

yaml
id: kafka_connector_restart
namespace: company.team

tasks:
  - id: restart_connector
    type: io.kestra.plugin.kafka.ConnectorRestart
    connectUrl: http://connect:8083
    connectorName: orders_jdbc_sink
    includeTasks: true
    onlyFailed: true

Properties

connectUrl *string

Kafka Connect REST API base URL

For example http://connect: 8083. Kafka Connect has no dedicated Java admin client — every operation goes through this REST API.

connectorName *string

Connector name

headers object

Additional HTTP headers

Sent on every request to the Connect REST API. Useful when the worker sits behind a reverse proxy or expects a bearer token, e.g. Authorization: Bearer ....

includeTasks booleanstring

Defaultfalse

Also restart the connector's tasks

Defaults to false, which restarts only the connector instance.

onlyFailed booleanstring

Defaultfalse

Restrict the restart to failed tasks only

Only applied when includeTasks is true. Defaults to false.

password string

Basic auth password

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

username string

Basic auth username

Required together with password when the Connect REST API is protected with HTTP basic auth. Leave both unset to call an unauthenticated worker — no Authorization header is sent in that case.

Outputs

connectorName string

Connector name

includeTasks boolean

Whether tasks were included in the restart

onlyFailed boolean

Whether the restart was restricted to failed tasks