public class ConsumerGroupDescription extends Object
Constructor and Description |
---|
ConsumerGroupDescription()
Constructor
|
ConsumerGroupDescription(JsonObject json)
Constructor (from JSON representation)
|
ConsumerGroupDescription(String groupId,
boolean isSimpleConsumerGroup,
List<MemberDescription> members,
String partitionAssignor,
org.apache.kafka.common.ConsumerGroupState state,
Node coordinator)
Constructor
|
Modifier and Type | Method and Description |
---|---|
Node |
getCoordinator() |
String |
getGroupId() |
List<MemberDescription> |
getMembers() |
String |
getPartitionAssignor() |
org.apache.kafka.common.ConsumerGroupState |
getState() |
boolean |
isSimpleConsumerGroup() |
ConsumerGroupDescription |
setCoordinator(Node coordinator)
Set the consumer group coordinator, or null if the coordinator is not known
|
ConsumerGroupDescription |
setGroupId(String groupId)
Set the id of the consumer group
|
ConsumerGroupDescription |
setMembers(List<MemberDescription> members)
Set a list of the members of the consumer group
|
ConsumerGroupDescription |
setPartitionAssignor(String partitionAssignor)
Set the consumer group partition assignor
|
ConsumerGroupDescription |
setSimpleConsumerGroup(boolean isSimpleConsumerGroup)
Set if consumer group is simple or not
|
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
|
JsonObject |
toJson()
Convert object to JSON representation
|
String |
toString() |
public ConsumerGroupDescription()
public ConsumerGroupDescription(String groupId, boolean isSimpleConsumerGroup, List<MemberDescription> members, String partitionAssignor, org.apache.kafka.common.ConsumerGroupState state, Node coordinator)
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 knownpublic ConsumerGroupDescription(JsonObject json)
json
- JSON representationpublic String getGroupId()
public ConsumerGroupDescription setGroupId(String groupId)
groupId
- the id of the consumer grouppublic boolean isSimpleConsumerGroup()
public ConsumerGroupDescription setSimpleConsumerGroup(boolean isSimpleConsumerGroup)
isSimpleConsumerGroup
- if consumer group is simple or notpublic Node getCoordinator()
public ConsumerGroupDescription setCoordinator(Node coordinator)
coordinator
- the consumer group coordinator, or null if the coordinator is not knownpublic List<MemberDescription> getMembers()
public ConsumerGroupDescription setMembers(List<MemberDescription> members)
members
- a list of the members of the consumer grouppublic String getPartitionAssignor()
public ConsumerGroupDescription setPartitionAssignor(String partitionAssignor)
partitionAssignor
- the consumer group partition assignorpublic org.apache.kafka.common.ConsumerGroupState getState()
public ConsumerGroupDescription setState(org.apache.kafka.common.ConsumerGroupState state)
state
- the consumer group state, or UNKNOWN if the state is too new for us to parsepublic JsonObject toJson()
Copyright © 2022 Eclipse. All rights reserved.