...
| Target Assignment | ||
|---|---|---|
| Name | Type | Description |
| Group ID | string | The group ID as configured by the consumer. The ID uniquely identifies the group. |
| Assignment Epoch | int32 | The epoch of the assignment. It represents the epoch of the group used to generate the assignment. It will eventually match the group epoch. |
| Assignment Error | int8 | The error reported by the assignor. |
| Members | []Member | The assignment for each member. |
| Member | ||
| Name | Type | Description |
| Member ID | string | The unique identifier of the member. |
| Partitions | []TopicIdPartition | The set of partitions assigned to this member. |
| Metadata | bytes | The metadata assigned to this member. |
Current Assignment
The current assignment of a member.
| Current Assignment | ||
|---|---|---|
| Name | Type | Description |
| Group ID | string | The group ID as configured by the consumer. The ID uniquely identifies the group. |
| Member ID | string | The member ID of this member. |
| Member Epoch | int32 | The current epoch of this member. The epoch is the assignment epoch of the assignment currently used by this member. |
| Error | int8 | The error reported by the assignor. |
| Partitions | []TopicIdPartition | The current partitions |
| used by the member. |
Rebalance process
The rebalance process is driven by the group coordinator and revolves around three kinds of epochs: the group epoch, the assignment epoch and the member epoch. This is intentionally very similar to how the process works for consumer groups in KIP-848.
...