connector_tasks

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

Overview

Name	connector_tasks
Type	Resource
Id	confluent.connect.connector_tasks

Fields

The following fields are returned by SELECT queries:

list_connectv1_connector_tasks

Connector Task.

Name	Datatype	Description
id	object	The ID of task.
config	object	Configuration parameters for the connector. These configurations are the minimum set of key-value pairs (KVP) which can be used to define how the connector connects Kafka to the external system. Some of these KVPs are common to all the connectors, such as connection parameters to Kafka, connector metadata, etc. The list of common connector configurations is as follows - cloud.environment - cloud.provider - connector.class - kafka.api.key - kafka.api.secret - kafka.endpoint - kafka.region - name A specific connector such as GcsSink would have additional parameters such as gcs.bucket.name, flush.size, etc.

Methods

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
list_connectv1_connector_tasks	select	connector_name, environment_id, kafka_cluster_id		Get a list of tasks currently running for the connector.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

Name	Datatype	Description
connector_name	string	The unique name of the connector.
environment_id	string	The unique identifier of the environment this resource belongs to.
kafka_cluster_id	string	The unique identifier for the Kafka cluster.

SELECT examples

list_connectv1_connector_tasks

Get a list of tasks currently running for the connector.

SELECT
id,
config
FROM confluent.connect.connector_tasks
WHERE connector_name = '{{ connector_name }}' -- required
AND environment_id = '{{ environment_id }}' -- required
AND kafka_cluster_id = '{{ kafka_cluster_id }}' -- required
;