| Package | Description | 
|---|---|
| io.vertx.kafka.admin | |
| io.vertx.reactivex.kafka.admin | |
| io.vertx.rxjava.kafka.admin | |
| io.vertx.rxjava3.kafka.admin | 
| Modifier and Type | Method and Description | 
|---|---|
| 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 | 
| Modifier and Type | Method and Description | 
|---|---|
| Future<Map<String,ConsumerGroupDescription>> | KafkaAdminClient. describeConsumerGroups(List<String> groupIds)Like  KafkaAdminClient.describeConsumerGroups(List, Handler)but returns aFutureof the asynchronous result | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | ConsumerGroupDescriptionConverter. fromJson(Iterable<Map.Entry<String,Object>> json,
        ConsumerGroupDescription obj) | 
| static void | ConsumerGroupDescriptionConverter. toJson(ConsumerGroupDescription obj,
      JsonObject json) | 
| static void | ConsumerGroupDescriptionConverter. toJson(ConsumerGroupDescription obj,
      Map<String,Object> json) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | KafkaAdminClient. describeConsumerGroups(List<String> groupIds,
                      Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)Describe some group ids in the cluster, with the default options | 
| Modifier and Type | Method and Description | 
|---|---|
| Single<Map<String,ConsumerGroupDescription>> | KafkaAdminClient. rxDescribeConsumerGroups(List<String> groupIds)Describe some group ids in the cluster, with the default options | 
| Modifier and Type | Method and Description | 
|---|---|
| void | KafkaAdminClient. describeConsumerGroups(List<String> groupIds,
                      Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)Describe some group ids in the cluster, with the default options | 
| Modifier and Type | Method and Description | 
|---|---|
| Single<Map<String,ConsumerGroupDescription>> | KafkaAdminClient. rxDescribeConsumerGroups(List<String> groupIds)Describe some group ids in the cluster, with the default options | 
| Modifier and Type | Method and Description | 
|---|---|
| void | KafkaAdminClient. describeConsumerGroups(List<String> groupIds,
                      Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)Describe some group ids in the cluster, with the default options | 
| Modifier and Type | Method and Description | 
|---|---|
| Single<Map<String,ConsumerGroupDescription>> | KafkaAdminClient. describeConsumerGroups(List<String> groupIds)Describe some group ids in the cluster, with the default options | 
| Single<Map<String,ConsumerGroupDescription>> | KafkaAdminClient. rxDescribeConsumerGroups(List<String> groupIds)Describe some group ids in the cluster, with the default options | 
Copyright © 2021 Eclipse. All rights reserved.