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 |
---|---|
DescribeClusterOptions |
DescribeClusterOptions.includeAuthorizedOperations(boolean includeAuthorizedOperations) |
Modifier and Type | Method and Description |
---|---|
Future<ClusterDescription> |
KafkaAdminClient.describeCluster(DescribeClusterOptions options)
Like
KafkaAdminClient.describeCluster(DescribeClusterOptions, Handler) but returns a Future of the asynchronous result |
void |
KafkaAdminClient.describeCluster(DescribeClusterOptions options,
Handler<AsyncResult<ClusterDescription>> completionHandler)
Like
KafkaAdminClient.describeCluster(Handler) but allows customized options. |
static void |
DescribeClusterOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
DescribeClusterOptions obj) |
static void |
DescribeClusterOptionsConverter.toJson(DescribeClusterOptions obj,
JsonObject json) |
static void |
DescribeClusterOptionsConverter.toJson(DescribeClusterOptions obj,
Map<String,Object> json) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeCluster(DescribeClusterOptions options)
Like
KafkaAdminClient.describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
void |
KafkaAdminClient.describeCluster(DescribeClusterOptions options,
Handler<AsyncResult<ClusterDescription>> completionHandler)
Like
KafkaAdminClient.describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
Single<ClusterDescription> |
KafkaAdminClient.rxDescribeCluster(DescribeClusterOptions options)
Like
KafkaAdminClient.describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeCluster(DescribeClusterOptions options)
Like
KafkaAdminClient.describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
void |
KafkaAdminClient.describeCluster(DescribeClusterOptions options,
Handler<AsyncResult<ClusterDescription>> completionHandler)
Like
KafkaAdminClient.describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
Single<ClusterDescription> |
KafkaAdminClient.rxDescribeCluster(DescribeClusterOptions options)
Like
KafkaAdminClient.describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
Modifier and Type | Method and Description |
---|---|
Single<ClusterDescription> |
KafkaAdminClient.describeCluster(DescribeClusterOptions options)
Like
KafkaAdminClient.describeCluster() but allows customized options. |
Single<ClusterDescription> |
KafkaAdminClient.rxDescribeCluster(DescribeClusterOptions options)
Like
KafkaAdminClient.describeCluster() but allows customized options. |
Copyright © 2023 Eclipse. All rights reserved.