Versions Compared

Key

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

...

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


LeaveGroupRequest => GroupId MemberId GroupInstanceIdList
  GroupId             => String

  MemberId            => String

  GroupInstanceIdList => list[String] // new

In the meantime, we bump the join group request/response version to v4.

...

Code Block
titleAdminClient.java
public static MembershipChangeResult invokeConsumerRebalanceremoveMemberFromGroup(String groupId);
public static MembershipChangeResult invokeConsumerRebalance(String groupId, InvokeConsumerRebalanceOptions, list<String> groupInstanceIds, RemoveMemberFromGroupOptions options);

In the meantime we shall introduce a type of request/response to make the API effective:

...