Skip to main content

kafka_clusters

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

Overview

Namekafka_clusters
TypeResource
Idconfluent.usm.kafka_clusters

Fields

The following fields are returned by SELECT queries:

Kafka 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_kafka_cluster_idstringThe unique identifier of the Kafka cluster within the Confluent Platform environment. (example: 4k0R9d1GTS5tI9f4Y2xZ0Q)
display_namestringA human-readable name for the Confluent Platform Kafka cluster. (example: My-Prod-CP-Cluster)
api_versionstringAPIVersion defines the schema version of this representation of a resource. (usm/v1)
cloudstringThe cloud service provider where the metadata for the Kafka Cluster should be stored. (example: AWS)
environmentobjectThe environment to which this belongs.
kindstringKind defines the object this REST resource represents. (KafkaCluster)
regionstringThe home region of the Confluent Platform Kafka cluster where the metadata should be stored. (example: us-east-1)

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
get_usm_v1_kafka_clusterselectenvironment, idMake a request to read a kafka cluster.
list_usm_v1_kafka_clustersselectenvironmentpage_size, page_tokenRetrieve a sorted, filtered, paginated list of all kafka clusters.
create_usm_v1_kafka_clusterinsertdisplay_name, confluent_platform_kafka_cluster_id, cloud, region, environmentMake a request to create a kafka cluster.
delete_usm_v1_kafka_clusterdeleteenvironment, idMake a request to delete a kafka 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 kafka cluster.
page_sizeintegerA pagination size for collection requests.
page_tokenstringAn opaque pagination token for collection requests.

SELECT examples

Make a request to read a kafka cluster.

SELECT
id,
confluent_platform_kafka_cluster_id,
display_name,
api_version,
cloud,
environment,
kind,
region
FROM confluent.usm.kafka_clusters
WHERE environment = '{{ environment }}' -- required
AND id = '{{ id }}' -- required
;

INSERT examples

Make a request to create a kafka cluster.

INSERT INTO confluent.usm.kafka_clusters (
display_name,
confluent_platform_kafka_cluster_id,
cloud,
region,
environment
)
SELECT
'{{ display_name }}' /* required */,
'{{ confluent_platform_kafka_cluster_id }}' /* required */,
'{{ cloud }}' /* required */,
'{{ region }}' /* required */,
'{{ environment }}' /* required */
RETURNING
id,
confluent_platform_kafka_cluster_id,
display_name,
api_version,
cloud,
environment,
kind,
region
;

DELETE examples

Make a request to delete a kafka cluster.

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