ConsumerGroupDescription |
ConsumerGroupDescription.setAuthorizedOperations(Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations) |
Set the id of the consumer group
|
ConsumerGroupDescription |
ConsumerGroupDescription.setCoordinator(Node coordinator) |
Set the consumer group coordinator, or null if the coordinator is not known
|
ConsumerGroupDescription |
ConsumerGroupDescription.setGroupId(String groupId) |
Set the id of the consumer group
|
ConsumerGroupDescription |
ConsumerGroupDescription.setMembers(List<MemberDescription> members) |
Set a list of the members of the consumer group
|
ConsumerGroupDescription |
ConsumerGroupDescription.setPartitionAssignor(String partitionAssignor) |
Set the consumer group partition assignor
|
ConsumerGroupDescription |
ConsumerGroupDescription.setSimpleConsumerGroup(boolean isSimpleConsumerGroup) |
Set if consumer group is simple or not
|
ConsumerGroupDescription |
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
|