Package 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	Description
ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, Collection<MemberDescription> members, String partitionAssignor, ConsumerGroupState state, Node coordinator)
ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, Collection<MemberDescription> members, String partitionAssignor, ConsumerGroupState state, Node coordinator, Set<AclOperation> authorizedOperations)
ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, Collection<MemberDescription> members, String partitionAssignor, GroupType type, ConsumerGroupState state, Node coordinator, Set<AclOperation> authorizedOperations)

Method Summary

Modifier and Type	Method	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()
GroupType	type()	The group type (or the protocol) of this consumer group.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ConsumerGroupDescription

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

ConsumerGroupDescription

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

ConsumerGroupDescription

public ConsumerGroupDescription(String groupId,
 boolean isSimpleConsumerGroup,
 Collection<MemberDescription> members,
 String partitionAssignor,
 GroupType type,
 ConsumerGroupState state,
 Node coordinator,
 Set<AclOperation> authorizedOperations)

Method Details

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.

type

public GroupType type()

The group type (or the protocol) of this consumer group. It defaults to Classic if not provided by the server.

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