vertx / io.vertx.rxjava.kafka.admin / AdminUtils

# AdminUtils

`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.

### Constructors

<init> | `AdminUtils(delegate: AdminUtils)`

### Properties

__TYPE_ARG | `static val __TYPE_ARG: TypeArg<AdminUtils>`

### Functions

changeTopicConfig | `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.
close | `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.
create | `open static fun create(vertx: Vertx, zookeeperHosts: String): AdminUtils` `open static fun create(vertx: Vertx, zookeeperHosts: String, autoClose: Boolean): AdminUtils` `open static fun create(vertx: Vertx, zookeeperHosts: String, connectionTimeoutMs: Int, isSecure: Boolean, autoClose: Boolean): AdminUtils` Create a new AdminUtils instance
createTopic | `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 `io.vertx.rxjava.kafka.admin.AdminUtils#createTopic`, one can pass in additional configuration parameters as a map (String -> String).
deleteTopic | `open fun deleteTopic(topicName: String, completionHandler: Handler<AsyncResult<Void>>): Unit` Delete the Kafka topic given by the topicName.
equals | `open fun equals(other: Any?): Boolean`
getDelegate | `open fun getDelegate(): AdminUtils`
hashCode | `open fun hashCode(): Int`
newInstance | `open static fun newInstance(arg: AdminUtils): AdminUtils`
rxChangeTopicConfig | `open fun rxChangeTopicConfig(topicName: String, topicConfig: MutableMap<String, String>): Single<Void>` Updates the configuration of the topic given by topicName. Configuration parameters are passed in as a Map (Key -> Value) of Strings.
rxClose | `open fun rxClose(): Single<Void>` 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.
rxCreateTopic | `open fun rxCreateTopic(topicName: String, partitionCount: Int, replicationFactor: Int): Single<Void>` 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>): Single<Void>` Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s). In contrast to @see `io.vertx.rxjava.kafka.admin.AdminUtils#createTopic`, one can pass in additional configuration parameters as a map (String -> String).
rxDeleteTopic | `open fun rxDeleteTopic(topicName: String): Single<Void>` Delete the Kafka topic given by the topicName.
rxTopicExists | `open fun rxTopicExists(topicName: String): Single<Boolean>` Checks if the Kafka topic given by topicName does exist.
toString | `open fun toString(): String`
topicExists | `open fun topicExists(topicName: String, completionHandler: Handler<AsyncResult<Boolean>>): Unit` Checks if the Kafka topic given by topicName does exist.