Class RemoveMembersFromConsumerGroupOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<RemoveMembersFromConsumerGroupOptions>
org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions

public class RemoveMembersFromConsumerGroupOptions extends AbstractOptions<RemoveMembersFromConsumerGroupOptions>
Options for Admin.removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions). It carries the members to be removed from the consumer group.
  • Constructor Details Link icon

    • RemoveMembersFromConsumerGroupOptions Link icon

      public RemoveMembersFromConsumerGroupOptions(Collection<MemberToRemove> members)
    • RemoveMembersFromConsumerGroupOptions Link icon

      public RemoveMembersFromConsumerGroupOptions()
  • Method Details Link icon

    • reason Link icon

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

      public Set<MemberToRemove> members()
    • reason Link icon

      public String reason()
    • removeAll Link icon

      public boolean removeAll()