cluster_configs
Creates, updates, deletes, gets or lists a cluster_configs resource.
Overview
| Name | cluster_configs |
| Type | Resource |
| Id | confluent.kafka.cluster_configs |
Fields
The following fields are returned by SELECT queries:
- get_kafka_cluster_config
- list_kafka_cluster_configs
The cluster configuration parameter.
| Name | Datatype | Description |
|---|---|---|
name | string | |
cluster_id | string | |
config_type | string | |
is_default | boolean | |
is_read_only | boolean | |
is_sensitive | boolean | |
kind | string | |
metadata | object | |
source | string | |
synonyms | array | |
value | string |
The list of cluster configs.
| Name | Datatype | Description |
|---|---|---|
name | string | |
cluster_id | string | |
config_type | string | |
is_default | boolean | |
is_read_only | boolean | |
is_sensitive | boolean | |
kind | string | |
metadata | object | |
source | string | |
synonyms | array | |
value | string |
Methods
The following methods are available for this resource:
| Name | Accessible by | Required Params | Optional Params | Description |
|---|---|---|---|---|
get_kafka_cluster_config | select | cluster_id, name, kafka_endpoint_id, region, cloud_provider | Return the dynamic cluster-wide broker configuration parameter specified by name. | |
list_kafka_cluster_configs | select | cluster_id, kafka_endpoint_id, region, cloud_provider | Return 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_config | replace | cluster_id, name, kafka_endpoint_id, region, cloud_provider | Update the dynamic cluster-wide broker configuration parameter specified by name. | |
update_kafka_cluster_configs | replace | cluster_id, kafka_endpoint_id, region, cloud_provider, data | Update or delete a set of dynamic cluster-wide broker configuration parameters. | |
delete_kafka_cluster_config | delete | cluster_id, name, kafka_endpoint_id, region, cloud_provider | Reset the configuration parameter specified by name to itsdefault 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.
| Name | Datatype | Description |
|---|---|---|
cloud_provider | string | Cloud provider, lowercase: aws, gcp, or azure (from the cluster spec.cloud). (default: cloud) |
cluster_id | string | The Kafka cluster ID. (example: cluster-1) |
kafka_endpoint_id | string | Per-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) |
name | string | The configuration parameter name. (example: compression.type) |
region | string | Cloud region the cluster runs in, e.g. ap-southeast-2 (from the cluster spec.region). (default: region) |
SELECT examples
- get_kafka_cluster_config
- list_kafka_cluster_configs
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
;
Return 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.
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 kafka_endpoint_id = '{{ kafka_endpoint_id }}' -- required
AND region = '{{ region }}' -- required
AND cloud_provider = '{{ cloud_provider }}' -- required
;
REPLACE examples
- update_kafka_cluster_config
- update_kafka_cluster_configs
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;
Update or delete a set of dynamic cluster-wide broker configuration parameters.
REPLACE confluent.kafka.cluster_configs
SET
data = '{{ data }}',
validate_only = {{ validate_only }}
WHERE
cluster_id = '{{ cluster_id }}' --required
AND kafka_endpoint_id = '{{ kafka_endpoint_id }}' --required
AND region = '{{ region }}' --required
AND cloud_provider = '{{ cloud_provider }}' --required
AND data = '{{ data }}' --required;
DELETE examples
- delete_kafka_cluster_config
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
;