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-345: Introduce static membership protocol to reduce consumer rebalances

Versions Compared


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


Code Block
public static MembershipChangeResult removeMemberFromGroupremoveMemberFromConsumerGroup(String groupId, list<String>RemoveMemberFromConsumerGroupOptions groupInstanceIdsToRemove, RemoveMemberFromGroupOptions options);

And a separate option class:

Code Block
public class RemoveMemberFromGroupOptions extends AbstractOptions<RemoveMemberFromGroupOptions> {
	private List<MemberIdentity> members; // members to be removed

which will use the latest LeaveGroupRequest API to inform broker the permanent leaving of a bunch of consumer instances.