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 |
---|---|
DescribeConsumerGroupsOptions |
DescribeConsumerGroupsOptions.includeAuthorizedOperations(boolean includeAuthorizedOperations) |
Modifier and Type | Method and Description |
---|---|
Future<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
Like
KafkaAdminClient.describeConsumerGroups(List, DescribeConsumerGroupsOptions, Handler) but returns a Future of the asynchronous result |
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Like
KafkaAdminClient.describeConsumerGroups(List, Handler) but allows customized options |
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
|
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.rxDescribeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
|
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.rxDescribeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
Modifier and Type | Method and Description |
---|---|
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
Like
KafkaAdminClient.describeConsumerGroups(java.util.List<java.lang.String>) but allows customized options |
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.rxDescribeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
Like
KafkaAdminClient.describeConsumerGroups(java.util.List<java.lang.String>) but allows customized options |
Copyright © 2024 Eclipse. All rights reserved.