Skip to main content

connect_clusters

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

Overview

Nameconnect_clusters
TypeResource
Idconfluent.usm.connect_clusters

Fields

The following fields are returned by SELECT queries:

Connect Cluster.

NameDatatypeDescription
idstringID is the "natural identifier" for an object within its scope/namespace; it is normally unique across time but not space. That is, you can assume that the ID will not be reclaimed and reused after an object is deleted ("time"); however, it may collide with IDs for other object kinds or objects of the same kind within a different scope/namespace ("space"). (example: dlz-f3a90de)
confluent_platform_connect_cluster_idstringThe unique identifier of the Connect cluster within the Confluent Platform environment. (example: connect-group-xyz123)
kafka_cluster_idstringThe unique identifier of the metadata Kafka cluster for the Connect Cluster. (example: 4k0R9d1GTS5tI9f4Y2xZ0Q)
api_versionstringAPIVersion defines the schema version of this representation of a resource. (usm/v1)
cloudstringThe cloud service provider where the metadata for the Connect Cluster should be stored. This field is optional. If provided, 'region' must also be provided. If neither 'cloud' nor 'region' are provided, the cloud provider of the associated metadata Kafka cluster (identified by 'kafka_cluster_id') will be used as a fallback. (example: AWS)
environmentobjectThe environment to which this belongs.
kindstringKind defines the object this REST resource represents. (ConnectCluster)
regionstringThe home region of the Confluent Platform Connect cluster where the metadata should be stored. This field is optional. If provided, 'cloud' must also be provided. If neither 'cloud' nor 'region' are provided, the home region of the associated metadata Kafka cluster (identified by 'kafka_cluster_id') will be used as a fallback. (example: us-east-1)

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
get_usm_v1_connect_clusterselectenvironment, idMake a request to read a connect cluster.
list_usm_v1_connect_clustersselectenvironmentpage_size, page_tokenRetrieve a sorted, filtered, paginated list of all connect clusters.
create_usm_v1_connect_clusterinsertconfluent_platform_connect_cluster_id, kafka_cluster_id, environmentMake a request to create a connect cluster.
delete_usm_v1_connect_clusterdeleteenvironment, idMake a request to delete a connect cluster.

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.

NameDatatypeDescription
environmentstringScope the operation to the given environment. (example: env-00000)
idstringThe unique identifier for the connect cluster.
page_sizeintegerA pagination size for collection requests.
page_tokenstringAn opaque pagination token for collection requests.

SELECT examples

Make a request to read a connect cluster.

SELECT
id,
confluent_platform_connect_cluster_id,
kafka_cluster_id,
api_version,
cloud,
environment,
kind,
region
FROM confluent.usm.connect_clusters
WHERE environment = '{{ environment }}' -- required
AND id = '{{ id }}' -- required
;

INSERT examples

Make a request to create a connect cluster.

INSERT INTO confluent.usm.connect_clusters (
confluent_platform_connect_cluster_id,
kafka_cluster_id,
cloud,
region,
environment
)
SELECT
'{{ confluent_platform_connect_cluster_id }}' /* required */,
'{{ kafka_cluster_id }}' /* required */,
'{{ cloud }}',
'{{ region }}',
'{{ environment }}' /* required */
RETURNING
id,
confluent_platform_connect_cluster_id,
kafka_cluster_id,
api_version,
cloud,
environment,
kind,
region
;

DELETE examples

Make a request to delete a connect cluster.

DELETE FROM confluent.usm.connect_clusters
WHERE environment = '{{ environment }}' --required
AND id = '{{ id }}' --required
;