| Package | Description | 
|---|---|
| io.vertx.kafka.admin | |
| io.vertx.reactivex.kafka.admin | |
| io.vertx.rxjava.kafka.admin | 
| Modifier and Type | Method and Description | 
|---|---|
ConsumerGroupListing | 
ConsumerGroupListing.setGroupId(String groupId)
Set the consumer group id 
 | 
ConsumerGroupListing | 
ConsumerGroupListing.setSimpleConsumerGroup(boolean isSimpleConsumerGroup)
Set if consumer group is simple or not 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
ConsumerGroupListingConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
        ConsumerGroupListing obj)  | 
static void | 
ConsumerGroupListingConverter.toJson(ConsumerGroupListing obj,
      JsonObject json)  | 
static void | 
ConsumerGroupListingConverter.toJson(ConsumerGroupListing obj,
      Map<String,Object> json)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<List<ConsumerGroupListing>> | 
KafkaAdminClient.rxListConsumerGroups()
Get the the consumer groups available in the cluster with the default options 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<List<ConsumerGroupListing>> | 
KafkaAdminClient.rxListConsumerGroups()
Get the the consumer groups available in the cluster with the default options 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options 
 | 
Copyright © 2020 Eclipse. All rights reserved.