@InterfaceStability.Evolving public class RemoveMembersFromConsumerGroupOptions extends AbstractOptions<RemoveMembersFromConsumerGroupOptions>
Admin.removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)
.
It carries the members to be removed from the consumer group.
The API of this class is evolving, see AdminClient
for details.Constructor and Description |
---|
RemoveMembersFromConsumerGroupOptions() |
RemoveMembersFromConsumerGroupOptions(Collection<MemberToRemove> members) |
Modifier and Type | Method and Description |
---|---|
Set<MemberToRemove> |
members() |
String |
reason() |
void |
reason(String reason)
Sets an optional reason.
|
boolean |
removeAll() |
timeoutMs, timeoutMs
public RemoveMembersFromConsumerGroupOptions(Collection<MemberToRemove> members)
public RemoveMembersFromConsumerGroupOptions()
public void reason(String reason)
public Set<MemberToRemove> members()
public String reason()
public boolean removeAll()