kafka.admin

AdminUtils

object AdminUtils extends Logging

Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. AdminUtils
  2. Logging
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. val TopicConfigChangeZnodePrefix : String

  7. def addPartitions (zkClient: ZkClient, topic: String, numPartitions: Int = 1, replicaAssignmentStr: String = "", checkBrokerAvailable: Boolean = true, config: Properties = new Properties): Unit

    Add partitions to existing topic with optional replica assignment

    Add partitions to existing topic with optional replica assignment

    zkClient

    Zookeeper client

    topic

    Topic for adding partitions to

    numPartitions

    Number of partitions to be set

    replicaAssignmentStr

    Manual replica assignment

    checkBrokerAvailable

    Ignore checking if assigned replica broker is available. Only used for testing

    config

    Pre-existing properties that should be preserved

  8. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  9. def assignReplicasToBrokers (brokerList: Seq[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)

  10. def changeTopicConfig (zkClient: ZkClient, topic: String, configs: Properties): Unit

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

  11. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  12. def createOrUpdateTopicPartitionAssignmentPathInZK (zkClient: ZkClient, topic: String, partitionReplicaAssignment: Map[Int, Seq[Int]], config: Properties = new Properties, update: Boolean = false): Unit

  13. def createTopic (zkClient: ZkClient, topic: String, partitions: Int, replicationFactor: Int, topicConfig: Properties = new Properties): Unit

  14. def debug (msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  15. def debug (e: ⇒ Throwable): Any

    Definition Classes
    Logging
  16. def debug (msg: ⇒ String): Unit

    Definition Classes
    Logging
  17. def deleteTopic (zkClient: ZkClient, topic: String): Unit

  18. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  19. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  20. def error (msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  21. def error (e: ⇒ Throwable): Any

    Definition Classes
    Logging
  22. def error (msg: ⇒ String): Unit

    Definition Classes
    Logging
  23. def fatal (msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  24. def fatal (e: ⇒ Throwable): Any

    Definition Classes
    Logging
  25. def fatal (msg: ⇒ String): Unit

    Definition Classes
    Logging
  26. def fetchAllTopicConfigs (zkClient: ZkClient): Map[String, Properties]

  27. def fetchTopicConfig (zkClient: ZkClient, topic: String): Properties

    Read the topic config (if any) from zk

  28. def fetchTopicMetadataFromZk (topics: Set[String], zkClient: ZkClient): Set[TopicMetadata]

  29. def fetchTopicMetadataFromZk (topic: String, zkClient: ZkClient): TopicMetadata

  30. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  31. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  32. def getManualReplicaAssignment (replicaAssignmentList: String, availableBrokerList: Set[Int], startPartitionId: Int, checkBrokerAvailable: Boolean = true): Map[Int, List[Int]]

  33. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  34. def info (msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  35. def info (e: ⇒ Throwable): Any

    Definition Classes
    Logging
  36. def info (msg: ⇒ String): Unit

    Definition Classes
    Logging
  37. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  38. var logIdent : String

    Attributes
    protected
    Definition Classes
    Logging
  39. lazy val logger : Logger

    Definition Classes
    Logging
  40. val loggerName : String

    Definition Classes
    Logging
  41. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  42. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  43. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  44. val rand : Random

  45. def swallow (action: ⇒ Unit): Unit

    Definition Classes
    Logging
  46. def swallowDebug (action: ⇒ Unit): Unit

    Definition Classes
    Logging
  47. def swallowError (action: ⇒ Unit): Unit

    Definition Classes
    Logging
  48. def swallowInfo (action: ⇒ Unit): Unit

    Definition Classes
    Logging
  49. def swallowTrace (action: ⇒ Unit): Unit

    Definition Classes
    Logging
  50. def swallowWarn (action: ⇒ Unit): Unit

    Definition Classes
    Logging
  51. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  52. def toString (): String

    Definition Classes
    AnyRef → Any
  53. def topicExists (zkClient: ZkClient, topic: String): Boolean

  54. def trace (msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  55. def trace (e: ⇒ Throwable): Any

    Definition Classes
    Logging
  56. def trace (msg: ⇒ String): Unit

    Definition Classes
    Logging
  57. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  58. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  59. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  60. def warn (msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging
  61. def warn (e: ⇒ Throwable): Any

    Definition Classes
    Logging
  62. def warn (msg: ⇒ String): Unit

    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any