Skip to main content

cluster_configs

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

Overview

Namecluster_configs
TypeResource
Idconfluent.kafka.cluster_configs

Fields

The following fields are returned by SELECT queries:

The cluster configuration parameter.

NameDatatypeDescription
namestring
cluster_idstring
config_typestring
is_defaultboolean
is_read_onlyboolean
is_sensitiveboolean
kindstring
metadataobject
sourcestring
synonymsarray
valuestring

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
get_kafka_cluster_configselectcluster_id, name, kafka_endpoint_id, region, cloud_providerReturn the dynamic cluster-wide broker configuration parameter specified by name.
list_kafka_cluster_configsselectcluster_id, kafka_endpoint_id, region, cloud_providerReturn a list of dynamic cluster-wide broker configuration parameters for the specified Kafka
cluster. Returns an empty list if there are no dynamic cluster-wide broker configuration parameters.
update_kafka_cluster_configreplacecluster_id, name, kafka_endpoint_id, region, cloud_providerUpdate the dynamic cluster-wide broker configuration parameter specified by name.
update_kafka_cluster_configsreplacecluster_id, kafka_endpoint_id, region, cloud_provider, dataUpdate or delete a set of dynamic cluster-wide broker configuration parameters.
delete_kafka_cluster_configdeletecluster_id, name, kafka_endpoint_id, region, cloud_providerReset the configuration parameter specified by name to its
default value by deleting a dynamic cluster-wide configuration.

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
cloud_providerstringCloud provider, lowercase: aws, gcp, or azure (from the cluster spec.cloud). (default: cloud)
cluster_idstringThe Kafka cluster ID. (example: cluster-1)
kafka_endpoint_idstringPer-cluster Kafka REST endpoint ID (the pkc-* host prefix from the Confluent UI Cluster -> Overview -> REST endpoint, or extract from confluent.managed_kafka_clusters.clusters spec.http_endpoint). (default: pkc-00000)
namestringThe configuration parameter name. (example: compression.type)
regionstringCloud region the cluster runs in, e.g. ap-southeast-2 (from the cluster spec.region). (default: region)

SELECT examples

Return the dynamic cluster-wide broker configuration parameter specified by name.

SELECT
name,
cluster_id,
config_type,
is_default,
is_read_only,
is_sensitive,
kind,
metadata,
source,
synonyms,
value
FROM confluent.kafka.cluster_configs
WHERE cluster_id = '{{ cluster_id }}' -- required
AND name = '{{ name }}' -- required
AND kafka_endpoint_id = '{{ kafka_endpoint_id }}' -- required
AND region = '{{ region }}' -- required
AND cloud_provider = '{{ cloud_provider }}' -- required
;

REPLACE examples

Update the dynamic cluster-wide broker configuration parameter specified by name.

REPLACE confluent.kafka.cluster_configs
SET
value = '{{ value }}'
WHERE
cluster_id = '{{ cluster_id }}' --required
AND name = '{{ name }}' --required
AND kafka_endpoint_id = '{{ kafka_endpoint_id }}' --required
AND region = '{{ region }}' --required
AND cloud_provider = '{{ cloud_provider }}' --required;

DELETE examples

Reset the configuration parameter specified by name to its
default value by deleting a dynamic cluster-wide configuration.

DELETE FROM confluent.kafka.cluster_configs
WHERE cluster_id = '{{ cluster_id }}' --required
AND name = '{{ name }}' --required
AND kafka_endpoint_id = '{{ kafka_endpoint_id }}' --required
AND region = '{{ region }}' --required
AND cloud_provider = '{{ cloud_provider }}' --required
;