org.apache.kafka.clients.admin

Class ConsumerGroupDescription

java.lang.Object

org.apache.kafka.clients.admin.ConsumerGroupDescription

public class ConsumerGroupDescription
extends Object

A detailed description of a single consumer group in the cluster.

Constructor Summary

Constructors

Constructor and Description
ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, Collection<MemberDescription> members, String partitionAssignor, ConsumerGroupState state, Node coordinator)

Method Summary

Modifier and Type	Method and Description
Set<AclOperation>	authorizedOperations() authorizedOperations for this group, or null if that information is not known.
Node	coordinator() The consumer group coordinator, or null if the coordinator is not known.
boolean	equals(Object o)
String	groupId() The id of the consumer group.
int	hashCode()
boolean	isSimpleConsumerGroup() If consumer group is simple or not.
Collection<MemberDescription>	members() A list of the members of the consumer group.
String	partitionAssignor() The consumer group partition assignor.
ConsumerGroupState	state() The consumer group state, or UNKNOWN if the state is too new for us to parse.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ConsumerGroupDescription

public ConsumerGroupDescription(String groupId,
                                boolean isSimpleConsumerGroup,
                                Collection<MemberDescription> members,
                                String partitionAssignor,
                                ConsumerGroupState state,
                                Node coordinator)

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

groupId

public String groupId()

The id of the consumer group.

isSimpleConsumerGroup

public boolean isSimpleConsumerGroup()

If consumer group is simple or not.

members

public Collection<MemberDescription> members()

A list of the members of the consumer group.

partitionAssignor

public String partitionAssignor()

The consumer group partition assignor.

state

public ConsumerGroupState state()

The consumer group state, or UNKNOWN if the state is too new for us to parse.

coordinator

public Node coordinator()

The consumer group coordinator, or null if the coordinator is not known.

authorizedOperations

public Set<AclOperation> authorizedOperations()

authorizedOperations for this group, or null if that information is not known.

toString

public String toString()

Overrides:

toString in class Object