| 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 | 
|---|---|
TopicDescription | 
TopicDescription.setInternal(boolean internal)
Set whether the topic is internal to Kafka. 
 | 
TopicDescription | 
TopicDescription.setName(String name)
Set the name of the topic. 
 | 
TopicDescription | 
TopicDescription.setPartitions(List<TopicPartitionInfo> partitions)
Set A list of partitions where the index represents the partition id and the element
 contains leadership and replica information for that partition. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Future<Map<String,TopicDescription>> | 
KafkaAdminClient.describeTopics(List<String> topicNames)
Like  
KafkaAdminClient.describeTopics(List, Handler) but returns a Future of the asynchronous result | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
TopicDescriptionConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
        TopicDescription obj)  | 
static void | 
TopicDescriptionConverter.toJson(TopicDescription obj,
      JsonObject json)  | 
static void | 
TopicDescriptionConverter.toJson(TopicDescription obj,
      Map<String,Object> json)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.describeTopics(List<String> topicNames,
              Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<Map<String,TopicDescription>> | 
KafkaAdminClient.rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.describeTopics(List<String> topicNames,
              Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<Map<String,TopicDescription>> | 
KafkaAdminClient.rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.describeTopics(List<String> topicNames,
              Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<Map<String,TopicDescription>> | 
KafkaAdminClient.describeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options. 
 | 
Single<Map<String,TopicDescription>> | 
KafkaAdminClient.rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options. 
 | 
Copyright © 2021 Eclipse. All rights reserved.