| Package | Description |
|---|---|
| io.vertx.kafka.admin | |
| io.vertx.reactivex.kafka.admin | |
| io.vertx.rxjava.kafka.admin |
| Modifier and Type | Method and Description |
|---|---|
ClusterDescription |
ClusterDescription.addNode(Node node)
Add a node belonging to this cluster to the current node list.
|
ClusterDescription |
ClusterDescription.setClusterId(String clusterId)
Set the cluster ID
|
ClusterDescription |
ClusterDescription.setController(Node controller)
Set the controller node.
|
ClusterDescription |
ClusterDescription.setNodes(List<Node> nodes)
Set the nodes belonging to this cluster
|
| Modifier and Type | Method and Description |
|---|---|
Future<ClusterDescription> |
KafkaAdminClient.describeCluster()
Like
KafkaAdminClient.describeCluster(Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
static void |
ClusterDescriptionConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
ClusterDescription obj) |
static void |
ClusterDescriptionConverter.toJson(ClusterDescription obj,
JsonObject json) |
static void |
ClusterDescriptionConverter.toJson(ClusterDescription obj,
Map<String,Object> json) |
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaAdminClient.describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
Describe the nodes in the cluster with the default options
|
| Modifier and Type | Method and Description |
|---|---|
Single<ClusterDescription> |
KafkaAdminClient.rxDescribeCluster()
Describe the nodes in the cluster with the default options
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaAdminClient.describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
Describe the nodes in the cluster with the default options
|
| Modifier and Type | Method and Description |
|---|---|
Single<ClusterDescription> |
KafkaAdminClient.rxDescribeCluster()
Describe the nodes in the cluster with the default options
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaAdminClient.describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
Describe the nodes in the cluster with the default options
|
Copyright © 2021 Eclipse. All rights reserved.