| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<AdminUtils> |
__TYPE_ARG |
| Constructor and Description |
|---|
AdminUtils(AdminUtils delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
changeTopicConfig(String topicName,
Map<String,String> topicConfig,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
|
void |
close(Handler<AsyncResult<Void>> completionHandler)
Deprecated.
|
static AdminUtils |
create(Vertx vertx,
String zookeeperHosts)
Deprecated.
|
static AdminUtils |
create(Vertx vertx,
String zookeeperHosts,
boolean autoClose)
Deprecated.
|
static AdminUtils |
create(Vertx vertx,
String zookeeperHosts,
int connectionTimeoutMs,
boolean isSecure,
boolean autoClose)
Deprecated.
|
void |
createTopic(String topicName,
int partitionCount,
int replicationFactor,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
|
void |
createTopic(String topicName,
int partitionCount,
int replicationFactor,
Map<String,String> topicConfig,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
|
void |
deleteTopic(String topicName,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
|
boolean |
equals(Object o) |
AdminUtils |
getDelegate() |
int |
hashCode() |
static AdminUtils |
newInstance(AdminUtils arg) |
Single<Void> |
rxChangeTopicConfig(String topicName,
Map<String,String> topicConfig)
Deprecated.
|
Single<Void> |
rxClose()
Deprecated.
|
Single<Void> |
rxCreateTopic(String topicName,
int partitionCount,
int replicationFactor)
Deprecated.
|
Single<Void> |
rxCreateTopic(String topicName,
int partitionCount,
int replicationFactor,
Map<String,String> topicConfig)
Deprecated.
|
Single<Void> |
rxDeleteTopic(String topicName)
Deprecated.
|
Single<Boolean> |
rxTopicExists(String topicName)
Deprecated.
|
void |
topicExists(String topicName,
Handler<AsyncResult<Boolean>> completionHandler)
Deprecated.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<AdminUtils> __TYPE_ARG
public AdminUtils(AdminUtils delegate)
public AdminUtils getDelegate()
@Deprecated public static AdminUtils create(Vertx vertx, String zookeeperHosts)
vertx - Vert.x instance to usezookeeperHosts - comma-separated list of Zookeeper server, e.g. localhost:2181,localhost:2182@Deprecated public static AdminUtils create(Vertx vertx, String zookeeperHosts, boolean autoClose)
vertx - Vert.x instance to usezookeeperHosts - comma-separated list of Zookeeper server, e.g. localhost:2181,localhost:2182autoClose - If set to true, the client will auto-close the connection after a command@Deprecated public static AdminUtils create(Vertx vertx, String zookeeperHosts, int connectionTimeoutMs, boolean isSecure, boolean autoClose)
vertx - Vert.x instance to usezookeeperHosts - comma-separated list of Zookeeper server, e.g. localhost:2181,localhost:2182connectionTimeoutMs - Maximum time in ms to wait for the client to connect to ZookeeperisSecure - If set to true, ZkUtils will perform security checks, i.e. ACL checksautoClose - If set to true, the client will auto-close the connection after a command@Deprecated public void createTopic(String topicName, int partitionCount, int replicationFactor, Handler<AsyncResult<Void>> completionHandler)
topicName - Name of the to-be-created topicpartitionCount - Number of partitionsreplicationFactor - Number of replicates. Must be lower or equal to the number of available BrokerscompletionHandler - vert.x callback@Deprecated public Single<Void> rxCreateTopic(String topicName, int partitionCount, int replicationFactor)
topicName - Name of the to-be-created topicpartitionCount - Number of partitionsreplicationFactor - Number of replicates. Must be lower or equal to the number of available Brokers@Deprecated public void createTopic(String topicName, int partitionCount, int replicationFactor, Map<String,String> topicConfig, Handler<AsyncResult<Void>> completionHandler)
createTopic(java.lang.String, int, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>), one can pass in additional configuration
parameters as a map (String -> String).topicName - Name of the to-be-created topicpartitionCount - Number of partitionsreplicationFactor - Number of replicates. Must be lower or equal to the number of available BrokerstopicConfig - map with additional topic configuration parameterscompletionHandler - vert.x callback@Deprecated public Single<Void> rxCreateTopic(String topicName, int partitionCount, int replicationFactor, Map<String,String> topicConfig)
createTopic(java.lang.String, int, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>), one can pass in additional configuration
parameters as a map (String -> String).topicName - Name of the to-be-created topicpartitionCount - Number of partitionsreplicationFactor - Number of replicates. Must be lower or equal to the number of available BrokerstopicConfig - map with additional topic configuration parameters@Deprecated public void deleteTopic(String topicName, Handler<AsyncResult<Void>> completionHandler)
topicName - Name of the topic to be deletedcompletionHandler - vert.x callback@Deprecated public Single<Void> rxDeleteTopic(String topicName)
topicName - Name of the topic to be deleted@Deprecated public void topicExists(String topicName, Handler<AsyncResult<Boolean>> completionHandler)
topicName - Name of the topiccompletionHandler - vert.x callback@Deprecated public Single<Boolean> rxTopicExists(String topicName)
topicName - Name of the topic@Deprecated public void changeTopicConfig(String topicName, Map<String,String> topicConfig, Handler<AsyncResult<Void>> completionHandler)
topicName - topic to be configuredtopicConfig - Map with configuration itemscompletionHandler - vert.x callback@Deprecated public Single<Void> rxChangeTopicConfig(String topicName, Map<String,String> topicConfig)
topicName - topic to be configuredtopicConfig - Map with configuration items@Deprecated public void close(Handler<AsyncResult<Void>> completionHandler)
completionHandler - vert.x callback@Deprecated public Single<Void> rxClose()
public static AdminUtils newInstance(AdminUtils arg)
Copyright © 2019 Eclipse. All rights reserved.