THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
class Subscription { ... public Optional<String> groupInstanceId(); } |
Similar to the MemberDescription interface (for describe group):
Code Block | ||||
---|---|---|---|---|
| ||||
class Subscription {
...
public Optional<String> groupInstanceId();
} |
We are also introducing a new error type. Will explain the handling in the following section.
...
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.
...