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 © 2023 Eclipse. All rights reserved.