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

    • reason

      public void reason(String reason)
      Sets an optional reason.
    • members

      public Set<MemberToRemove> members()
    • reason

      public String reason()
    • removeAll

      public boolean removeAll()