...
The AssignmentEpoch corresponds to the group epoch used to compute the assignment. It is not necessarily the last onenecessarily the most recent group epoch because the assignment is computed asynchronously when a client-side assignor is used. When a client side assignor is used, the assignment is computed asynchronously. While it is computed for the group at epoch X, the group may have already advanced to epoch X+1 due to another event (e.g. new member joined). In this case, we have chosen to install the assignment computed for epoch X and to trigger a new assignment computation right away.
ConsumerGroupTargetAssignmentMemberKey
| Code Block |
|---|
| language | js |
|---|
| linenumbers | true |
|---|
|
{
"type": "data",
"name": "ConsumerGroupTargetAssignmentMemberKey",
"validVersions": "7",
"flexibleVersions": "none",
"fields": [
{ "name": "GroupId", "type": "string", "versions": "7" },
{ "name": "MemberId", "type": "string", "versions": "7" }
]
} |
ConsumerGroupTargetAssignmentMemberValue
| Code Block |
|---|
| language | js |
|---|
| linenumbers | true |
|---|
|
{
"type": "data",
"name": "ConsumerGroupTargetAssignmentMemberValue",
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{ "name": "AssignmentEpoch", "versions": "0+", "type": "int32" },
{ "name": "MemberId", "versions": "0+", "type": "string" },
{ "name": "Error", "versions": "0+", "type": "int8" },
{ "name": "TopicPartitions", "versions": "0+",
"type": "[]TopicPartition", "fields": [
{ "name": "TopicId", "versions": "0+", "type": "uuid" },
{ "name": "Partitions", "versions": "0+", "type": "[]int32" }
]},
{ "name": "VersionMetadataVersion", "versions": "0+", "type": "int16" },
{ "name": "MetadataMetadataBytes", "versions": "0+", "type": "bytes" }
]
} |
...
| Code Block |
|---|
| language | js |
|---|
| linenumbers | true |
|---|
|
{
"type": "data",
"name": "ConsumerGroupCurrentMemberAssignmentKey",
"validVersions": "8",
"flexibleVersions": "none",
"fields": [
{ "name": "GroupId", "type": "string", "versions": "78" },
{ "name": "MemberId", "type": "string", "versions": "78" },
]
} |
ConsumerGroupCurrentMemberAssignmentValue
| Code Block |
|---|
| language | js |
|---|
| linenumbers | true |
|---|
|
{
"type": "data",
"name": "ConsumerGroupCurrentMemberAssignmentValue",
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{ "name": "MemberEpoch", "versions": "0+", "type": "int32" },
{ "name": "Error", "versions": "0+", "type": "int8" },
{ "name": "TopicPartitions", "versions": "0+",
"type": "[]TopicPartition", "fields": [
{ "name": "TopicId", "versions": "0+", "type": "uuid" },
{ "name": "Partitions", "versions": "0+", "type": "[]int32" }
]},
{ "name": "VersionMetadataVersion", "versions": "0+", "type": "int16" },
{ "name": "MetadataMetadataBytes", "versions": "0+", "type": "bytes" }
],
} |
...