open class AdminUtils
Provides a wrapper around important methods in Kafka's AdminUtils, namely NOTE: This class has been automatically generated from the io.vertx.kafka.admin.AdminUtils non RX-ified interface using Vert.x codegen.
AdminUtils(delegate: AdminUtils) |
static val __TYPE_ARG: TypeArg<AdminUtils> |
open fun changeTopicConfig(topicName: String, topicConfig: MutableMap<String, String>, completionHandler: Handler<AsyncResult<Void>>): Unit
Updates the configuration of the topic given by topicName. Configuration parameters are passed in as a Map (Key -> Value) of Strings. |
|
open fun close(completionHandler: Handler<AsyncResult<Void>>): Unit
Closes the underlying connection to Zookeeper. It is required to call the method for cleanup purposes if AdminUtils was not created with autoClose set to true. |
|
open static fun create(vertx: Vertx, zookeeperHosts: String): AdminUtilsopen static fun create(vertx: Vertx, zookeeperHosts: String, autoClose: Boolean): AdminUtilsopen static fun create(vertx: Vertx, zookeeperHosts: String, connectionTimeoutMs: Int, isSecure: Boolean, autoClose: Boolean): AdminUtils
Create a new AdminUtils instance |
|
open fun createTopic(topicName: String, partitionCount: Int, replicationFactor: Int, completionHandler: Handler<AsyncResult<Void>>): Unit
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s) open fun createTopic(topicName: String, partitionCount: Int, replicationFactor: Int, topicConfig: MutableMap<String, String>, completionHandler: Handler<AsyncResult<Void>>): Unit
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s). In contrast to @see |
|
open fun deleteTopic(topicName: String, completionHandler: Handler<AsyncResult<Void>>): Unit
Delete the Kafka topic given by the topicName. |
|
open fun equals(other: Any?): Boolean |
|
open fun getDelegate(): AdminUtils |
|
open fun hashCode(): Int |
|
open static fun newInstance(arg: AdminUtils): AdminUtils |
|
open fun rxChangeTopicConfig(topicName: String, topicConfig: MutableMap<String, String>): Completable
Updates the configuration of the topic given by topicName. Configuration parameters are passed in as a Map (Key -> Value) of Strings. |
|
open fun rxClose(): Completable
Closes the underlying connection to Zookeeper. It is required to call the method for cleanup purposes if AdminUtils was not created with autoClose set to true. |
|
open fun rxCreateTopic(topicName: String, partitionCount: Int, replicationFactor: Int): Completable
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s) open fun rxCreateTopic(topicName: String, partitionCount: Int, replicationFactor: Int, topicConfig: MutableMap<String, String>): Completable
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s). In contrast to @see |
|
open fun rxDeleteTopic(topicName: String): Completable
Delete the Kafka topic given by the topicName. |
|
open fun rxTopicExists(topicName: String): Single<Boolean>
Checks if the Kafka topic given by topicName does exist. |
|
open fun toString(): String |
|
open fun topicExists(topicName: String, completionHandler: Handler<AsyncResult<Boolean>>): Unit
Checks if the Kafka topic given by topicName does exist. |