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

create

open static fun create(vertx: Vertx, zookeeperHosts: String): AdminUtils

Create a new AdminUtils instance

Parameters

vertx - Vert.x instance to use

zookeeperHosts - comma-separated list of Zookeeper server, e.g. localhost:2181,localhost:2182

Return
an instance of the AdminUtilWrapper

open static fun create(vertx: Vertx, zookeeperHosts: String, autoClose: Boolean): AdminUtils

Create a new AdminUtils instance

Parameters

vertx - Vert.x instance to use

zookeeperHosts - comma-separated list of Zookeeper server, e.g. localhost:2181,localhost:2182

autoClose - If set to true, the client will auto-close the connection after a command

Return
an instance of the AdminUtilWrapper

open static fun create(vertx: Vertx, zookeeperHosts: String, connectionTimeoutMs: Int, isSecure: Boolean, autoClose: Boolean): AdminUtils

Create a new AdminUtils instance

Parameters

vertx - Vert.x instance to use

zookeeperHosts - comma-separated list of Zookeeper server, e.g. localhost:2181,localhost:2182

connectionTimeoutMs - Maximum time in ms to wait for the client to connect to Zookeeper

isSecure - If set to true, ZkUtils will perform security checks, i.e. ACL checks

autoClose - If set to true, the client will auto-close the connection after a command

Return
an instance of the AdminUtilWrapper