Skip to main content

clusters

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

Overview

Nameclusters
TypeResource
Idconfluent.ksqldb_clusters.clusters

Fields

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").
_specobject
api_versionstringAPIVersion defines the schema version of this representation of a resource.
kindstringKind defines the object this REST resource represents.
metadata``ObjectMeta is metadata that all persisted resources must have, which includes all objects users must create.
specobjectThe desired state of the Cluster
statusobjectThe status of the Cluster

Methods

NameAccessible byRequired ParamsDescription
get_ksqldbcm_v2clusterSELECTenvironment, idGeneral Availability Make a request to read a cluster.
list_ksqldbcm_v2clustersSELECTenvironmentGeneral Availability Retrieve a sorted, filtered, paginated list of all clusters.
create_ksqldbcm_v2clusterINSERTGeneral Availability Make a request to create a cluster.
delete_ksqldbcm_v2clusterDELETEenvironment, idGeneral Availability Make a request to delete a cluster.

SELECT examples

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

SELECT
id,
_spec,
api_version,
kind,
metadata,
spec,
status
FROM confluent.ksqldb_clusters.clusters
WHERE environment = '{{ environment }}';

INSERT example

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

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

DELETE example

Deletes the specified clusters resource.

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