Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Changes will be applied to join group request, and sync group request and offset commit request to include member name and other settings: 

Code Block
JoinGroupRequest => GroupId SessionTimeout RebalanceTimeout MemberId MemberName ProtocolType GroupProtocols
  GroupId             => String
  SessionTimeout      => int32
  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.

...