Package org.apache.kafka.clients.admin
Class ConsumerGroupDescription
- java.lang.Object
-
- org.apache.kafka.clients.admin.ConsumerGroupDescription
-
public class ConsumerGroupDescription extends java.lang.Object
A detailed description of a single consumer group in the cluster.
-
-
Constructor Summary
Constructors Constructor Description ConsumerGroupDescription(java.lang.String groupId, boolean isSimpleConsumerGroup, java.util.Collection<MemberDescription> members, java.lang.String partitionAssignor, ConsumerGroupState state, Node coordinator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.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(java.lang.Object o)
java.lang.String
groupId()
The id of the consumer group.int
hashCode()
boolean
isSimpleConsumerGroup()
If consumer group is simple or not.java.util.Collection<MemberDescription>
members()
A list of the members of the consumer group.java.lang.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.java.lang.String
toString()
-
-
-
Constructor Detail
-
ConsumerGroupDescription
public ConsumerGroupDescription(java.lang.String groupId, boolean isSimpleConsumerGroup, java.util.Collection<MemberDescription> members, java.lang.String partitionAssignor, ConsumerGroupState state, Node coordinator)
-
-
Method Detail
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
groupId
public java.lang.String groupId()
The id of the consumer group.
-
isSimpleConsumerGroup
public boolean isSimpleConsumerGroup()
If consumer group is simple or not.
-
members
public java.util.Collection<MemberDescription> members()
A list of the members of the consumer group.
-
partitionAssignor
public java.lang.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 java.util.Set<AclOperation> authorizedOperations()
authorizedOperations for this group, or null if that information is not known.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-