This Confluence has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems file an INFRA jira ticket please.

Child pages
  • KIP-469: Pre-registration support for static members

Versions Compared

Key

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

...

Code Block
JoinGroupRequest => GroupId SessionTimeout RebalanceTimeout MemberId GroupInstanceId ProtocolType GroupProtocols
  GroupId             => String
  SessionTimeout      => int32
  RebalanceTimeout    => int32
  MemberId            => String // removed
  GroupInstanceId     => String // removed
  ProtocolType        => String 
  GroupProtocols      => [Protocol MemberMetadata]
  Protocol            => String // removed
  MemberMetadata      => bytes  // removed
  JoinGroupMembers    => []JoinGroupRequestMember // new
 						   MemberId            => String // new
						   GroupInstanceId     => String // new
						   Protocol            => String // new

JoinGroupResponse => ThrottleTime ErrorCode GenerationId ProtocolName LeaderId MemberId Members
  ThrottleTime           => int16
  ErrorCode              => int16  // removed
  GenerationId           => int32
  ProtocolName           => String
  LeaderId               => String
  MemberId               => String // removed
  Members                => []JoinGroupResponseMember 	
							  MemberId         => String
                              GroupInstanceId  => String
                              Metadata         => bytes
  MemberJoinResponseList => []JoinGroupResult  // new
							  MemberInfo  => JoinGroupResponseMember // new	
							  ErrorCode   => int16 // new

A new admin request shall be created for user to supply a list of `group.instance.id` to batch join the group:

Code Block
languagejava
titleAdminClient.java
public static AddMemberResult addMemberToGroupaddMembersToGroup(String groupId, list<String> groupInstanceIdsToAdd, AddMemberToGroupOptions options);

...