member_assignments
Creates, updates, deletes, gets or lists a member_assignments resource.
Overview
| Name | member_assignments |
| Type | Resource |
| Id | confluent.streams_group.member_assignments |
Fields
The following fields are returned by SELECT queries:
- get_kafka_streams_group_member_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_assignments | select | cluster_id, group_id, member_id | Return the 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 |
|---|---|---|
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) |
SELECT examples
- get_kafka_streams_group_member_assignments
Return the 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 confluent.streams_group.member_assignments
WHERE cluster_id = '{{ cluster_id }}' -- required
AND group_id = '{{ group_id }}' -- required
AND member_id = '{{ member_id }}' -- required
;