Uses of Class
io.vertx.kafka.admin.ConsumerGroupDescription
-
Packages that use ConsumerGroupDescription Package Description io.vertx.kafka.admin io.vertx.reactivex.kafka.admin io.vertx.rxjava3.kafka.admin -
-
Uses of ConsumerGroupDescription in io.vertx.kafka.admin
Methods in io.vertx.kafka.admin that return ConsumerGroupDescription Modifier and Type Method Description ConsumerGroupDescription
ConsumerGroupDescription. setAuthorizedOperations(Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Set the id of the consumer groupConsumerGroupDescription
ConsumerGroupDescription. setCoordinator(Node coordinator)
Set the consumer group coordinator, or null if the coordinator is not knownConsumerGroupDescription
ConsumerGroupDescription. setGroupId(String groupId)
Set the id of the consumer groupConsumerGroupDescription
ConsumerGroupDescription. setMembers(List<MemberDescription> members)
Set a list of the members of the consumer groupConsumerGroupDescription
ConsumerGroupDescription. setPartitionAssignor(String partitionAssignor)
Set the consumer group partition assignorConsumerGroupDescription
ConsumerGroupDescription. setSimpleConsumerGroup(boolean isSimpleConsumerGroup)
Set if consumer group is simple or notConsumerGroupDescription
ConsumerGroupDescription. setState(org.apache.kafka.common.ConsumerGroupState state)
Set the consumer group state, or UNKNOWN if the state is too new for us to parseMethods in io.vertx.kafka.admin that return types with arguments of type ConsumerGroupDescription Modifier and Type Method Description Future<Map<String,ConsumerGroupDescription>>
KafkaAdminClient. describeConsumerGroups(List<String> groupIds)
Describe some group ids in the cluster, with the default optionsFuture<Map<String,ConsumerGroupDescription>>
KafkaAdminClient. describeConsumerGroups(List<String> groupIds, DescribeConsumerGroupsOptions options)
LikeKafkaAdminClient.describeConsumerGroups(List)
but allows customized options -
Uses of ConsumerGroupDescription in io.vertx.reactivex.kafka.admin
-
Uses of ConsumerGroupDescription in io.vertx.rxjava3.kafka.admin
-