Package | Description |
---|---|
io.vertx.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,
io.vertx.core.json.JsonObject json) |
static void |
ConsumerGroupListingConverter.toJson(ConsumerGroupListing obj,
Map<String,Object> json) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.listConsumerGroups(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options
|
Copyright © 2020 Eclipse. All rights reserved.