Package io.vertx.kafka.admin
Class ConsumerGroupDescription
- java.lang.Object
-
- io.vertx.kafka.admin.ConsumerGroupDescription
-
public class ConsumerGroupDescription extends Object
A detailed description of a single consumer group in the cluster
-
-
Constructor Summary
Constructors Constructor Description ConsumerGroupDescription()ConstructorConsumerGroupDescription(JsonObject json)Constructor (from JSON representation)ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, List<MemberDescription> members, String partitionAssignor, org.apache.kafka.common.ConsumerGroupState state, Node coordinator, Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)Constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Set<org.apache.kafka.common.acl.AclOperation>getAuthorizedOperations()NodegetCoordinator()StringgetGroupId()List<MemberDescription>getMembers()StringgetPartitionAssignor()org.apache.kafka.common.ConsumerGroupStategetState()booleanisSimpleConsumerGroup()ConsumerGroupDescriptionsetAuthorizedOperations(Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)Set the id of the consumer groupConsumerGroupDescriptionsetCoordinator(Node coordinator)Set the consumer group coordinator, or null if the coordinator is not knownConsumerGroupDescriptionsetGroupId(String groupId)Set the id of the consumer groupConsumerGroupDescriptionsetMembers(List<MemberDescription> members)Set a list of the members of the consumer groupConsumerGroupDescriptionsetPartitionAssignor(String partitionAssignor)Set the consumer group partition assignorConsumerGroupDescriptionsetSimpleConsumerGroup(boolean isSimpleConsumerGroup)Set if consumer group is simple or notConsumerGroupDescriptionsetState(org.apache.kafka.common.ConsumerGroupState state)Set the consumer group state, or UNKNOWN if the state is too new for us to parseJsonObjecttoJson()Convert object to JSON representationStringtoString()
-
-
-
Constructor Detail
-
ConsumerGroupDescription
public ConsumerGroupDescription()
Constructor
-
ConsumerGroupDescription
public ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, List<MemberDescription> members, String partitionAssignor, org.apache.kafka.common.ConsumerGroupState state, Node coordinator, Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Constructor- Parameters:
groupId- the id of the consumer groupisSimpleConsumerGroup- if consumer group is simple or notmembers- a list of the members of the consumer grouppartitionAssignor- the consumer group partition assignorstate- the consumer group state, or UNKNOWN if the state is too new for us to parsecoordinator- the consumer group coordinator, or null if the coordinator is not knownauthorizedOperations- authorizedOperations for this group, or null if that information is not known.
-
ConsumerGroupDescription
public ConsumerGroupDescription(JsonObject json)
Constructor (from JSON representation)- Parameters:
json- JSON representation
-
-
Method Detail
-
getGroupId
public String getGroupId()
- Returns:
- the id of the consumer group
-
setGroupId
public ConsumerGroupDescription setGroupId(String groupId)
Set the id of the consumer group- Parameters:
groupId- the id of the consumer group- Returns:
- current instance of the class to be fluent
-
isSimpleConsumerGroup
public boolean isSimpleConsumerGroup()
- Returns:
- if consumer group is simple or not
-
setSimpleConsumerGroup
public ConsumerGroupDescription setSimpleConsumerGroup(boolean isSimpleConsumerGroup)
Set if consumer group is simple or not- Parameters:
isSimpleConsumerGroup- if consumer group is simple or not- Returns:
- current instance of the class to be fluent
-
getCoordinator
public Node getCoordinator()
- Returns:
- the consumer group coordinator, or null if the coordinator is not known
-
setCoordinator
public ConsumerGroupDescription setCoordinator(Node coordinator)
Set the consumer group coordinator, or null if the coordinator is not known- Parameters:
coordinator- the consumer group coordinator, or null if the coordinator is not known- Returns:
- current instance of the class to be fluent
-
getMembers
public List<MemberDescription> getMembers()
- Returns:
- a list of the members of the consumer group
-
setMembers
public ConsumerGroupDescription setMembers(List<MemberDescription> members)
Set a list of the members of the consumer group- Parameters:
members- a list of the members of the consumer group- Returns:
- current instance of the class to be fluent
-
getPartitionAssignor
public String getPartitionAssignor()
- Returns:
- the consumer group partition assignor
-
setPartitionAssignor
public ConsumerGroupDescription setPartitionAssignor(String partitionAssignor)
Set the consumer group partition assignor- Parameters:
partitionAssignor- the consumer group partition assignor- Returns:
- current instance of the class to be fluent
-
getState
public org.apache.kafka.common.ConsumerGroupState getState()
- Returns:
- the consumer group state, or UNKNOWN if the state is too new for us to parse
-
setState
public ConsumerGroupDescription setState(org.apache.kafka.common.ConsumerGroupState state)
Set the consumer group state, or UNKNOWN if the state is too new for us to parse- Parameters:
state- the consumer group state, or UNKNOWN if the state is too new for us to parse- Returns:
- current instance of the class to be fluent
-
getAuthorizedOperations
public Set<org.apache.kafka.common.acl.AclOperation> getAuthorizedOperations()
- Returns:
- authorizedOperations authorizedOperations for this group, or null if that information is not known.
-
setAuthorizedOperations
public ConsumerGroupDescription setAuthorizedOperations(Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Set the id of the consumer group- Parameters:
authorizedOperations- authorizedOperations for this group, or null if that information is not known.- Returns:
- current instance of the class to be fluent
-
toJson
public JsonObject toJson()
Convert object to JSON representation- Returns:
- JSON representation
-
-