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