Apache Kafka ConnectorGetStatus
CertifiedGet the status of a Kafka Connect connector
Apache Kafka ConnectorGetStatus
Get the status of a Kafka Connect connector
Returns the connector's own state and the state of each of its tasks, as typed fields — outputs.x.connectorState and outputs.x.tasks[*].state can be used directly in flow conditions without parsing a raw JSON blob.
type: io.kestra.plugin.kafka.ConnectorGetStatusExamples
Fail the flow when a connector isn't running
id: kafka_connector_get_status
namespace: company.team
tasks:
- id: get_status
type: io.kestra.plugin.kafka.ConnectorGetStatus
connectUrl: http://connect:8083
connectorName: orders_jdbc_sink
- id: check_running
type: io.kestra.plugin.core.flow.If
condition: "{{ outputs.get_status.connectorState != 'RUNNING' }}"
then:
- id: fail
type: io.kestra.plugin.core.execution.Fail
Properties
connectUrl *Requiredstring
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 *Requiredstring
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 ....
password string
Basic auth password
pluginDefaultsRef Non-dynamicstring
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
connectorState string
Connector state
e.g. RUNNING, PAUSED, STOPPED, FAILED, UNASSIGNED.
tasks array
Status of each task provisioned for this connector
io.kestra.plugin.kafka.ConnectorGetStatus-TaskStatus
Task id
Task state
e.g. RUNNING, PAUSED, FAILED, UNASSIGNED.
Stack trace, present only when the task is in FAILED state
Id of the worker running this task
workerId string
Id of the worker running the connector instance
