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)
-
Method Summary
All Methods Instance Methods Concrete Methods 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()
-
-
-
Constructor Detail
-
ConsumerGroupDescription
public ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, Collection<MemberDescription> members, String partitionAssignor, ConsumerGroupState state, Node coordinator)
-
-
Method Detail
-
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.
-
-