connector_status
Creates, updates, deletes, gets or lists a connector_status
resource.
Overview
Name | connector_status |
Type | Resource |
Id | confluent.connect.connector_status |
Fields
Name | Datatype | Description |
---|---|---|
name | string | The name of the connector. |
connector | object | The map containing connector status. |
tasks | array | The map containing the task status. |
type | string | Type of connector, sink or source. |
Methods
Name | Accessible by | Required Params | Description |
---|---|---|---|
read_connectv1connector_status | SELECT | connector_name, environment_id, kafka_cluster_id | Get current status of the connector. This includes whether it is running, failed, or paused. Also includes which worker it is assigned to, error information if it has failed, and the state of all its tasks. |
SELECT
examples
Get current status of the connector. This includes whether it is running, failed, or paused. Also includes which worker it is assigned to, error information if it has failed, and the state of all its tasks.
SELECT
name,
connector,
tasks,
type
FROM confluent.connect.connector_status
WHERE connector_name = '{{ connector_name }}'
AND environment_id = '{{ environment_id }}'
AND kafka_cluster_id = '{{ kafka_cluster_id }}';