Skip to main content

clusters

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

Overview

Nameclusters
TypeResource
Idconfluent.managed_kafka_clusters.clusters

Fields

NameDatatypeDescription
idtextID 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").
api_endpointtextfield from the parent object
api_versiontextAPIVersion defines the schema version of this representation of a resource.
availabilitytextfield from the parent object
cloudtextfield from the parent object
config_kindtextfield from the parent object
created_attextfield from the parent object
display_nametextfield from the parent object
environmenttextfield from the parent object
environment_idtextfield from the parent object
environment_relatedtextfield from the parent object
environment_resource_nametextfield from the parent object
http_endpointtextfield from the parent object
kafka_bootstrap_endpointtextfield from the parent object
kindtextKind defines the object this REST resource represents.
regiontextfield from the parent object
resource_nametextfield from the parent object
selftextfield from the parent object
status_phasetextfield from the parent object
updated_attextfield from the parent object

Methods

NameAccessible byRequired ParamsDescription
get_cmk_v2clusterSELECTenvironment, idGeneral Availability Make a request to read a cluster.
list_cmk_v2clustersSELECTenvironmentGeneral Availability Retrieve a sorted, filtered, paginated list of all clusters.
create_cmk_v2clusterINSERTGeneral Availability Make a request to create a cluster.
delete_cmk_v2clusterDELETEenvironment, idGeneral Availability Make a request to delete a cluster.
update_cmk_v2clusterUPDATEidGeneral Availability Make a request to update a cluster.

SELECT examples

General Availability Retrieve a sorted, filtered, paginated list of all clusters.

SELECT
id,
api_endpoint,
api_version,
availability,
cloud,
config_kind,
created_at,
display_name,
environment,
environment_id,
environment_related,
environment_resource_name,
http_endpoint,
kafka_bootstrap_endpoint,
kind,
region,
resource_name,
self,
status_phase,
updated_at
FROM confluent.managed_kafka_clusters.vw_clusters
WHERE environment = '{{ environment }}';

INSERT example

Use the following StackQL query and manifest file to create a new clusters resource.

/*+ create */
INSERT INTO confluent.managed_kafka_clusters.clusters (
data__spec
)
SELECT
'{{ spec }}'
;

UPDATE example

Updates a clusters resource.

/*+ update */
UPDATE confluent.managed_kafka_clusters.clusters
SET
spec = '{{ spec }}'
WHERE
id = '{{ id }}';

DELETE example

Deletes the specified clusters resource.

/*+ delete */
DELETE FROM confluent.managed_kafka_clusters.clusters
WHERE environment = '{{ environment }}'
AND id = '{{ id }}';