Apache Kafka ConnectorGetConfig
CertifiedGet a Kafka Connect connector's configuration
Apache Kafka ConnectorGetConfig
Get a Kafka Connect connector's configuration
Returns the connector's current configuration. The output config has the same shape as ConnectorCreate's config input, so it can be piped directly into ConnectorCreate or ConnectorUpdateConfig to clone or restore a connector.
type: io.kestra.plugin.kafka.ConnectorGetConfigExamples
Clone a connector's config into a new connector
id: kafka_connector_clone
namespace: company.team
tasks:
- id: get_config
type: io.kestra.plugin.kafka.ConnectorGetConfig
connectUrl: http://connect:8083
connectorName: orders_jdbc_sink
- id: create_clone
type: io.kestra.plugin.kafka.ConnectorCreate
connectUrl: http://connect:8083
connectorName: orders_jdbc_sink_clone
config: "{{ outputs.get_config.config }}"
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
config object
Connector configuration
Same shape as ConnectorCreate's config input — pass directly to ConnectorCreate.config or ConnectorUpdateConfig.config.
connectorName string
Connector name
