Class RemoveMembersFromConsumerGroupOptions

java.lang.Object
org.apache.kafka.clients.admin.AbstractOptions<RemoveMembersFromConsumerGroupOptions>
org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions
public class RemoveMembersFromConsumerGroupOptionsextends AbstractOptions<RemoveMembersFromConsumerGroupOptions>
Options for Admin.removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions). It carries the members to be removed from the consumer group.

  • 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()