RemoveMembersFromConsumerGroupOptions (kafka 4.0.0 API)

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 Summary

Constructors

Constructor

Description

RemoveMembersFromConsumerGroupOptions()

RemoveMembersFromConsumerGroupOptions(Collection<MemberToRemove> members)
Method Summary

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

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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