KafkaAdminClientImpl instead.@Deprecated public class AdminUtilsImpl extends Object implements AdminUtils
| Constructor and Description |
|---|
AdminUtilsImpl(Vertx vertx,
String zookeeperHosts)
Deprecated.
|
AdminUtilsImpl(Vertx vertx,
String zookeeperHosts,
boolean autoClose)
Deprecated.
|
AdminUtilsImpl(Vertx vertx,
String zookeeperHosts,
int connectionTimeoutMs,
boolean isSecure,
boolean autoClose)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
changeTopicConfig(String topicName,
Map<String,String> topicConfig,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
Updates the configuration of the topic given by topicName.
|
void |
close(Handler<AsyncResult<Void>> completionHandler)
Deprecated.
Closes the underlying connection to Zookeeper.
|
void |
createTopic(String topicName,
int partitionCount,
int replicationFactor,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s)
|
void |
createTopic(String topicName,
int partitionCount,
int replicationFactor,
Map<String,String> topicConfig,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s).
|
void |
deleteTopic(String topicName,
Handler<AsyncResult<Void>> completionHandler)
Deprecated.
Delete the Kafka topic given by the topicName.
|
void |
topicExists(String topicName,
Handler<AsyncResult<Boolean>> completionHandler)
Deprecated.
Checks if the Kafka topic given by topicName does exist.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreate, create, createpublic AdminUtilsImpl(Vertx vertx, String zookeeperHosts, int connectionTimeoutMs, boolean isSecure, boolean autoClose)
public void createTopic(String topicName, int partitionCount, int replicationFactor, Handler<AsyncResult<Void>> completionHandler)
AdminUtilscreateTopic in interface AdminUtilstopicName - 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 callbackpublic void createTopic(String topicName, int partitionCount, int replicationFactor, Map<String,String> topicConfig, Handler<AsyncResult<Void>> completionHandler)
AdminUtilsAdminUtils.createTopic(String, int, int, Handler), one can pass in additional configuration
parameters as a map (String -> String).createTopic in interface AdminUtilstopicName - 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 callbackpublic void deleteTopic(String topicName, Handler<AsyncResult<Void>> completionHandler)
AdminUtilsdeleteTopic in interface AdminUtilstopicName - Name of the topic to be deletedcompletionHandler - vert.x callbackpublic void topicExists(String topicName, Handler<AsyncResult<Boolean>> completionHandler)
AdminUtilstopicExists in interface AdminUtilstopicName - Name of the topiccompletionHandler - vert.x callbackpublic void changeTopicConfig(String topicName, Map<String,String> topicConfig, Handler<AsyncResult<Void>> completionHandler)
AdminUtilschangeTopicConfig in interface AdminUtilstopicName - topic to be configuredtopicConfig - Map with configuration itemscompletionHandler - vert.x callbackpublic void close(Handler<AsyncResult<Void>> completionHandler)
AdminUtilsclose in interface AdminUtilscompletionHandler - vert.x callbackCopyright © 2020. All rights reserved.