Apache Kafka ConnectorList
CertifiedList Kafka Connect connectors
Apache Kafka ConnectorList
List Kafka Connect connectors
Returns every connector name on the worker. Set expandStatus: true to also fetch each connector's status in the same call, avoiding one ConnectorGetStatus call per connector.
type: io.kestra.plugin.kafka.ConnectorListExamples
List connectors with their status
id: kafka_connector_list
namespace: company.team
tasks:
- id: list_connectors
type: io.kestra.plugin.kafka.ConnectorList
connectUrl: http://connect:8083
expandStatus: true
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.
expandStatus booleanstring
falseFetch each connector's status alongside its name
Defaults to false.
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
connectorNames array
Connector names
connectors array
Per-connector status
Empty unless expandStatus was true.
io.kestra.plugin.kafka.ConnectorGetStatus-Output
Connector name
Connector state
e.g. RUNNING, PAUSED, STOPPED, FAILED, UNASSIGNED.
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
Id of the worker running the connector instance
