THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
JoinGroupRequest => GROUP_ID => STRING SESSION_TIMEOUT => INT32 REBALANCE_TIMEOUT => INT32 STATIC_REGISTRATION_TIMEOUT => INT32 // NEW STATIC_EXPANSION_TIMEOUT => INT32 // NEW MEMBER_NAME => INT32 // NEW PROTOCOL_TYPE => STRING GROUP_PROTOCOLS => ARRAY offsetCommitRequest => GROUP_ID => STRING GENERATION_ID => STRING MEMBER_ID => STRING MEMBER_NAMES => STRING // NEW TOPICS => PARTITION DATA |
If the broker version is not the latest (< v4), the join group request shall be downgraded to v3 without setting the member Id.
We shall also bump the join group request/response version to v4.
| Code Block | ||||
|---|---|---|---|---|
| ||||
public static Schema[] schemaVersions() {
return new Schema[] {JOIN_GROUP_REQUEST_V0, JOIN_GROUP_REQUEST_V1, JOIN_GROUP_REQUEST_V2, JOIN_GROUP_REQUEST_V3, JOIN_GROUP_REQUEST_V4};
} |
If the broker version is not the latest (< v4), the join group request shall be downgraded to v3 without setting the member Id.
...
| Code Block | ||
|---|---|---|
| ||
public static Schema[] schemaVersions() {
return new Schema[] {JOIN_GROUP_RESPONSE_V0, JOIN_GROUP_RESPONSE_V1, JOIN_GROUP_RESPONSE_V2, JOIN_GROUP_RESPONSE_V3, JOIN_GROUP_RESPONSE_V4};
} |
...