member_target_assignments

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

Overview

Name	member_target_assignments
Type	Resource
Id	kafka.streams_group.member_target_assignments

Fields

The following fields are returned by SELECT queries:

get_kafka_streams_group_member_target_assignments

The streams group member assignments.

Name	Datatype	Description
cluster_id	string	The unique identifier of the Kafka cluster.
group_id	string	The unique identifier of the Streams group.
member_id	string	The unique identifier of the Streams group member.
active_tasks	object
kind	string
metadata	object
standby_tasks	object
warmup_tasks	object

Methods

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
get_kafka_streams_group_member_target_assignments	select	cluster_id, group_id, member_id, kafka_endpoint_id, region, cloud_provider		Return the target assignments of the member specified by the member_id.

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)
group_id	string	The group ID. (example: group-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)
member_id	string	The streams member ID. (example: member-1)
region	string	Cloud region the cluster runs in, e.g. ap-southeast-2 (from the cluster spec.region). (default: region)

SELECT examples

get_kafka_streams_group_member_target_assignments

Return the target assignments of the member specified by the member_id.

SELECT
cluster_id,
group_id,
member_id,
active_tasks,
kind,
metadata,
standby_tasks,
warmup_tasks
FROM kafka.streams_group.member_target_assignments
WHERE cluster_id = '{{ cluster_id }}' -- required
AND group_id = '{{ group_id }}' -- required
AND member_id = '{{ member_id }}' -- required
AND kafka_endpoint_id = '{{ kafka_endpoint_id }}' -- required
AND region = '{{ region }}' -- required
AND cloud_provider = '{{ cloud_provider }}' -- required
;