Skip to main content

connector_status

Creates, updates, deletes, gets or lists a connector_status resource.

Overview

Nameconnector_status
TypeResource
Idconfluent.connect.connector_status

Fields

NameDatatypeDescription
namestringThe name of the connector.
connectorobjectThe map containing connector status.
tasksarrayThe map containing the task status.
typestringType of connector, sink or source.

Methods

NameAccessible byRequired ParamsDescription
read_connectv1connector_statusSELECTconnector_name, environment_id, kafka_cluster_idGet 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 }}';