member_target_assignment_task_partitions

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

Overview

Name	member_target_assignment_task_partitions
Type	Resource
Id	confluent.streams_group.member_target_assignment_task_partitions

Fields

The following fields are returned by SELECT queries:

get_kafka_streams_group_member_target_assignment_task_partitions

The partitions of a streams member task.

Name	Datatype	Description
subtopology_id	string	The unique identifier of the Streams subtopology.
kind	string
metadata	object
partition_ids	array	The list of partition IDs assigned to the Streams task.

Methods

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
get_kafka_streams_group_member_target_assignment_task_partitions	select	cluster_id, group_id, member_id, assignments_type, subtopology_id		Return the tasks of the member specified by the member_id, and the type assignments_type.

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
assignments_type	string	The streams member Assignment type. (example: active)
cluster_id	string	The Kafka cluster ID. (example: cluster-1)
group_id	string	The group ID. (example: group-1)
member_id	string	The streams member ID. (example: member-1)
subtopology_id	string	The streams subtopology ID. (example: subtopology-1)

SELECT examples

get_kafka_streams_group_member_target_assignment_task_partitions

Return the tasks of the member specified by the member_id, and the type assignments_type.

SELECT
subtopology_id,
kind,
metadata,
partition_ids
FROM confluent.streams_group.member_target_assignment_task_partitions
WHERE cluster_id = '{{ cluster_id }}' -- required
AND group_id = '{{ group_id }}' -- required
AND member_id = '{{ member_id }}' -- required
AND assignments_type = '{{ assignments_type }}' -- required
AND subtopology_id = '{{ subtopology_id }}' -- required
;