< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package utils

  Definition Classes
    manager
-  package logkafka81
  Definition Classes
    utils
-  package logkafka82
  Definition Classes
    utils
-  package one10
  Definition Classes
    utils
-  package two00
  Definition Classes
    utils
-  package zero10
  Definition Classes
    utils
-  package zero11
  Definition Classes
    utils
-  package zero81
  Definition Classes
    utils
-  package zero82
  Definition Classes
    utils
-  package zero90
  Definition Classes
    utils
- AdminUtils
- FiniteQueue
- Logkafka
- LogkafkaAdminUtils
- LogkafkaErrors
- LogkafkaNewConfigs
- LogkafkaZkUtils
- LongFormatted
- Topic
- TopicConfigs
- TopicErrors
- UtilError
- UtilException
- ZkUtils
- repeatWithIndex

c

kafka.manager.utils

# AdminUtils 

###

#### class AdminUtils extends Logging

Borrowed from kafka 0.8.1.1, adapted to use curator framework https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/admin/AdminUtils.scala

Linear Supertypes
Logging, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. AdminUtils
2. Logging
3. AnyRef
4. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new AdminUtils(version: KafkaVersion)

### Value Members

1.  final def !=(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
2.  final def ##(): Int
   Definition Classes
     AnyRef → Any
3.  final def ==(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
4.  val TopicConfigChangeZnodePrefix: String
5.  def addPartitions(curator: CuratorFramework, topic: String, newNumPartitions: Int, partitionReplicaList: Map[Int, Seq[Int]], brokerList: Set[Int], readVersion: Int): Unit

   Add partitions to existing topic with optional replica assignment

   Add partitions to existing topic with optional replica assignment

   curator

     Zookeeper client

   topic

     topic for adding partitions to

   newNumPartitions

     Number of partitions to be set

   partitionReplicaList

     current partition to replic set mapping

   brokerList

     broker list

6.  def addPartitionsToTopics(curator: CuratorFramework, topicAndReplicaList: Seq[(String, Map[Int, Seq[Int]])], newNumPartitions: Int, brokerList: Set[Int], readVersions: Map[String, Int]): Unit
7.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
8.  def assignReplicasToBrokers(brokerListSet: Set[Int], nPartitions: Int, replicationFactor: Int, fixedStartIndex: Int = -1, startPartitionId: Int = -1): Map[Int, Seq[Int]]

   There are 2 goals of replica assignment: 1.

   There are 2 goals of replica assignment: 1. Spread the replicas evenly among brokers. 2. For partitions assigned to a particular broker, their other replicas are spread over the other brokers.

   To achieve this goal, we: 1. Assign the first replica of each partition by round-robin, starting from a random position in the broker list. 2. Assign the remaining replicas of each partition with an increasing shift.

   Here is an example of assigning broker-0 broker-1 broker-2 broker-3 broker-4 p0 p1 p2 p3 p4 (1st replica) p5 p6 p7 p8 p9 (1st replica) p4 p0 p1 p2 p3 (2nd replica) p8 p9 p5 p6 p7 (2nd replica) p3 p4 p0 p1 p2 (3nd replica) p7 p8 p9 p5 p6 (3nd replica)

9.  def changeTopicConfig(curator: CuratorFramework, topic: String, config: Properties, readVersion: Int): Unit

   Update the config for an existing topic and create a change notification so the change will propagate to other brokers

10.  def clone(): AnyRef
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
11.  def createOrUpdateTopicPartitionAssignmentPathInZK(curator: CuratorFramework, topic: String, partitionReplicaAssignment: Map[Int, Seq[Int]], config: Properties = new Properties, update: Boolean = false, readVersion: Int = -1): Unit
12.  def createTopic(curator: CuratorFramework, brokers: Set[Int], topic: String, partitions: Int, replicationFactor: Int, topicConfig: Properties = new Properties): Unit
13.  def debug(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
14.  def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
15.  def debug(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
16.  def deleteTopic(curator: CuratorFramework, topic: String): Unit
17.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
18.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
19.  def error(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
20.  def error(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
21.  def error(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
22.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
23.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
24.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
25.  def info(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
26.  def info(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
27.  def info(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
28.  def isDebugEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
29.  def isErrorEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
30.  def isInfoEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
31.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
32.  def isTraceEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
33.  def isWarnEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
34.  def logger: Logger
    Attributes
      protected
    Definition Classes
      Logging
35.  def loggerName: String
    Attributes
      protected
    Definition Classes
      Logging
36.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
37.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
38.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
39.  val rand: Random
40.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
41.  def toString(): String
    Definition Classes
      AnyRef → Any
42.  def topicExists(curator: CuratorFramework, topic: String): Boolean
43.  def trace(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
44.  def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
45.  def trace(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
46.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
47.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
48.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
49.  def warn(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
50.  def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
51.  def warn(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging

### Inherited from Logging

### Inherited from AnyRef

### Inherited from Any

### Ungrouped