vertx / io.vertx.reactivex.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.reactivex.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>): Completable

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(): 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.

rxCreateTopic

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 io.vertx.reactivex.kafka.admin.AdminUtils#createTopic, one can pass in additional configuration parameters as a map (String -> String).

rxDeleteTopic

open fun rxDeleteTopic(topicName: String): Completable

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.