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 |
---|---|
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 |
---|---|
Future<List<ConsumerGroupListing>> |
KafkaAdminClient.listConsumerGroups()
Like
KafkaAdminClient.listConsumerGroups(Handler) but returns a Future of the asynchronous result |
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
|
Modifier and Type | Method and Description |
---|---|
Single<List<ConsumerGroupListing>> |
KafkaAdminClient.listConsumerGroups()
Get the the consumer groups available in the cluster with the default options
|
Single<List<ConsumerGroupListing>> |
KafkaAdminClient.rxListConsumerGroups()
Get the the consumer groups available in the cluster with the default options
|
Copyright © 2024 Eclipse. All rights reserved.