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 |
---|---|
NewPartitions |
NewPartitions.setNewAssignments(List<List<Integer>> assignments)
Set the assignment for the new partitions
|
NewPartitions |
NewPartitions.setTotalCount(int totalCount)
Set the number of partitions for the topic
|
Modifier and Type | Method and Description |
---|---|
Future<Void> |
KafkaAdminClient.createPartitions(Map<String,NewPartitions> partitions)
Like
KafkaAdminClient.createPartitions(Map, Handler) but returns a Future of the asynchronous result |
void |
KafkaAdminClient.createPartitions(Map<String,NewPartitions> partitions,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new partitions in the Kafka topic
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.createPartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
void |
KafkaAdminClient.createPartitions(Map<String,NewPartitions> partitions,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new partitions in the Kafka topic
|
Completable |
KafkaAdminClient.rxCreatePartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.createPartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
void |
KafkaAdminClient.createPartitions(Map<String,NewPartitions> partitions,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new partitions in the Kafka topic
|
Single<Void> |
KafkaAdminClient.rxCreatePartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
Modifier and Type | Method and Description |
---|---|
Completable |
KafkaAdminClient.createPartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
Completable |
KafkaAdminClient.rxCreatePartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
Copyright © 2024 Eclipse. All rights reserved.