THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Changes will be applied to join group request, sync group request and offset commit request to include member name and other settings:
| Code Block |
|---|
JoinGroupRequest => GROUP_ID => STRING SESSION_TIMEOUT => INT32 REBALANCE_TIMEOUT => INT32 MEMBER_NAME => INT32 // NEW PROTOCOL_TYPE => STRING GROUP_PROTOCOLS => ARRAY offsetCommitRequestJoinGroupRequest => GroupId SessionTimeout RebalanceTimeout MemberId MemberName ProtocolType GroupProtocols GROUP_ID => STRING GENERATION_ID => STRING MEMBER_ID GroupId => STRINGString MEMBER_NAMESessionTimeout => STRING // NEW TOPICS => PARTITION DATAint32 RebalanceTimeout => int32 MemberId => String MemberName => String // new ProtocolType => String GroupProtocols => [Protocol MemberMetadata] Protocol => String MemberMetadata => bytes SyncGroupRequest => GroupId GroupGenerationId MemberId MemberName GroupId => String GroupGenerationId => int32 GroupState => [MemberId MemberState] MemberId => String MemberName => String // new MemberState => bytes OffsetCommitRequest => GroupId GenerationId MemberId MemberName Topics GroupId => String GenerationId => String MemberId => String MemberName => 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.
...