Package org.apache.kafka.clients.admin
Class RemoveMembersFromConsumerGroupOptions
- java.lang.Object
-
- org.apache.kafka.clients.admin.AbstractOptions<RemoveMembersFromConsumerGroupOptions>
-
- org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions
-
@Evolving public class RemoveMembersFromConsumerGroupOptions extends AbstractOptions<RemoveMembersFromConsumerGroupOptions>
Options forAdmin.removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)
. It carries the members to be removed from the consumer group. The API of this class is evolving, seeAdminClient
for details.
-
-
Constructor Summary
Constructors Constructor Description RemoveMembersFromConsumerGroupOptions()
RemoveMembersFromConsumerGroupOptions(Collection<MemberToRemove> members)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Set<MemberToRemove>
members()
String
reason()
void
reason(String reason)
Sets an optional reason.boolean
removeAll()
-
Methods inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs, timeoutMs
-
-
-
-
Constructor Detail
-
RemoveMembersFromConsumerGroupOptions
public RemoveMembersFromConsumerGroupOptions(Collection<MemberToRemove> members)
-
RemoveMembersFromConsumerGroupOptions
public RemoveMembersFromConsumerGroupOptions()
-
-
Method Detail
-
reason
public void reason(String reason)
Sets an optional reason.
-
members
public Set<MemberToRemove> members()
-
reason
public String reason()
-
removeAll
public boolean removeAll()
-
-