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 for 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 Details

    • RemoveMembersFromConsumerGroupOptions

      public RemoveMembersFromConsumerGroupOptions​(Collection<MemberToRemove> members)
    • RemoveMembersFromConsumerGroupOptions

      public RemoveMembersFromConsumerGroupOptions()
  • Method Details

    • members

      public Set<MemberToRemove> members()
    • removeAll

      public boolean removeAll()