Uses of Class
io.vertx.kafka.admin.NewTopic
-
Packages that use NewTopic Package Description io.vertx.kafka.admin io.vertx.reactivex.kafka.admin io.vertx.rxjava3.kafka.admin -
-
Uses of NewTopic in io.vertx.kafka.admin
Methods in io.vertx.kafka.admin that return NewTopic Modifier and Type Method Description NewTopic
NewTopic. setConfig(Map<String,String> config)
Set the configuration for the new topic or null if no configs ever specifiedNewTopic
NewTopic. setName(String name)
Set the name of the topic to be createdNewTopic
NewTopic. setNumPartitions(int numPartitions)
Set the number of partitions for the new topic or -1 if a replica assignment has been specifiedNewTopic
NewTopic. setReplicasAssignments(Map<Integer,List<Integer>> replicasAssignments)
Set a map from partition id to replica idsNewTopic
NewTopic. setReplicationFactor(short replicationFactor)
Set the replication factor for the new topic or -1 if a replica assignment has been specifiedMethod parameters in io.vertx.kafka.admin with type arguments of type NewTopic Modifier and Type Method Description Future<Void>
KafkaAdminClient. createTopics(List<NewTopic> topics)
Creates a batch of new Kafka topics -
Uses of NewTopic in io.vertx.reactivex.kafka.admin
Method parameters in io.vertx.reactivex.kafka.admin with type arguments of type NewTopic Modifier and Type Method Description Future<Void>
KafkaAdminClient. createTopics(List<NewTopic> topics)
Creates a batch of new Kafka topicsCompletable
KafkaAdminClient. rxCreateTopics(List<NewTopic> topics)
Creates a batch of new Kafka topics -
Uses of NewTopic in io.vertx.rxjava3.kafka.admin
Method parameters in io.vertx.rxjava3.kafka.admin with type arguments of type NewTopic Modifier and Type Method Description Completable
KafkaAdminClient. createTopics(List<NewTopic> topics)
Creates a batch of new Kafka topicsCompletable
KafkaAdminClient. rxCreateTopics(List<NewTopic> topics)
Creates a batch of new Kafka topics
-