class AdminUtils extends AnyRef
Provides a wrapper around important methods in Kafka's AdminUtils, namely
- Alphabetic
- By Inheritance
- AdminUtils
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new AdminUtils(_asJava: AnyRef)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asJava: AnyRef
-
def
changeTopicConfig(topicName: String, topicConfig: Map[String, String], completionHandler: Handler[AsyncResult[Unit]]): Unit
Updates the configuration of the topic given by topicName.
Updates the configuration of the topic given by topicName. Configuration parameters are passed in as a Map (Key -> Value) of Strings. * @param topicName topic to be configured
- topicConfig
Map with configuration items
- completionHandler
vert.x callback
-
def
changeTopicConfigFuture(topicName: String, topicConfig: Map[String, String]): Future[Unit]
Like changeTopicConfig but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
close(completionHandler: Handler[AsyncResult[Unit]]): Unit
Closes the underlying connection to Zookeeper.
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. * @param completionHandler vert.x callback
-
def
closeFuture(): Future[Unit]
Like close but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
createTopic(topicName: String, partitionCount: Int, replicationFactor: Int, topicConfig: Map[String, String], completionHandler: Handler[AsyncResult[Unit]]): Unit
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s).
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s). In contrast to @see io.vertx.scala.kafka.admin.AdminUtils#createTopic, one can pass in additional configuration parameters as a map (String -> String). * @param topicName Name of the to-be-created topic
- partitionCount
Number of partitions
- replicationFactor
Number of replicates. Must be lower or equal to the number of available Brokers
- topicConfig
map with additional topic configuration parameters
- completionHandler
vert.x callback
-
def
createTopic(topicName: String, partitionCount: Int, replicationFactor: Int, completionHandler: Handler[AsyncResult[Unit]]): Unit
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s) * @param topicName Name of the to-be-created topic
Creates a new Kafka topic on all Brokers managed by the given Zookeeper instance(s) * @param topicName Name of the to-be-created topic
- partitionCount
Number of partitions
- replicationFactor
Number of replicates. Must be lower or equal to the number of available Brokers
- completionHandler
vert.x callback
-
def
createTopicFuture(topicName: String, partitionCount: Int, replicationFactor: Int, topicConfig: Map[String, String]): Future[Unit]
Like createTopic but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
createTopicFuture(topicName: String, partitionCount: Int, replicationFactor: Int): Future[Unit]
Like createTopic but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
deleteTopic(topicName: String, completionHandler: Handler[AsyncResult[Unit]]): Unit
Delete the Kafka topic given by the topicName.
Delete the Kafka topic given by the topicName. * @param topicName Name of the topic to be deleted
- completionHandler
vert.x callback
-
def
deleteTopicFuture(topicName: String): Future[Unit]
Like deleteTopic but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
topicExists(topicName: String, completionHandler: Handler[AsyncResult[Boolean]]): Unit
Checks if the Kafka topic given by topicName does exist.
Checks if the Kafka topic given by topicName does exist. * @param topicName Name of the topic
- completionHandler
vert.x callback
-
def
topicExistsFuture(topicName: String): Future[Boolean]
Like topicExists but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )