| Package | Description | 
|---|---|
| io.vertx.kafka.admin | |
| io.vertx.reactivex.kafka.admin | |
| io.vertx.rxjava.kafka.admin | 
| Modifier and Type | Method and Description | 
|---|---|
NewTopic | 
NewTopic.setConfig(Map<String,String> config)
Set the configuration for the new topic or null if no configs ever specified 
 | 
NewTopic | 
NewTopic.setName(String name)
Set the name of the topic to be created 
 | 
NewTopic | 
NewTopic.setNumPartitions(int numPartitions)
Set the number of partitions for the new topic or -1 if a replica assignment has been specified 
 | 
NewTopic | 
NewTopic.setReplicasAssignments(Map<Integer,List<Integer>> replicasAssignments)
Set a map from partition id to replica ids 
 | 
NewTopic | 
NewTopic.setReplicationFactor(short replicationFactor)
Set the replication factor for the new topic or -1 if a replica assignment has been specified 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
NewTopicConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
        NewTopic obj)  | 
static void | 
NewTopicConverter.toJson(NewTopic obj,
      JsonObject json)  | 
static void | 
NewTopicConverter.toJson(NewTopic obj,
      Map<String,Object> json)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.createTopics(List<NewTopic> topics,
            Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.createTopics(List<NewTopic> topics,
            Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics 
 | 
Completable | 
KafkaAdminClient.rxCreateTopics(List<NewTopic> topics)
Creates a batch of new Kafka topics 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.createTopics(List<NewTopic> topics,
            Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics 
 | 
Single<Void> | 
KafkaAdminClient.rxCreateTopics(List<NewTopic> topics)
Creates a batch of new Kafka topics 
 | 
Copyright © 2020 Eclipse. All rights reserved.