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 *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.
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150expandStatus 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
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
