kafka.admin

AdminUtils

object AdminUtils extends Logging

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
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

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

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

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

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

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

    Definition Classes
    Any
  6. val AdminClientId: String

  7. val EntityConfigChangeZnodePrefix: String

  8. def addPartitions(zkUtils: ZkUtils, topic: String, numPartitions: Int = 1, replicaAssignmentStr: String = "", checkBrokerAvailable: Boolean = true): Unit

    Add partitions to existing topic with optional replica assignment

    Add partitions to existing topic with optional replica assignment

    zkUtils

    Zookeeper utilities

    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

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. 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)

  11. def changeClientIdConfig(zkUtils: ZkUtils, clientId: String, configs: Properties): Unit

    Update the config for a client and create a change notification so the change will propagate to other brokers

    Update the config for a client and create a change notification so the change will propagate to other brokers

    zkUtils

    Zookeeper utilities used to write the config to ZK

  12. def changeTopicConfig(zkUtils: ZkUtils, 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

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

    zkUtils

    Zookeeper utilities used to write the config to ZK

  13. def clone(): AnyRef

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

  15. def createTopic(zkUtils: ZkUtils, topic: String, partitions: Int, replicationFactor: Int, topicConfig: Properties = new Properties): Unit

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

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

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

    Definition Classes
    Logging
  19. def deleteAllConsumerGroupInfoForTopicInZK(zkUtils: ZkUtils, topic: String): Unit

    Delete every inactive consumer group's information about the given topic in Zookeeper.

    Delete every inactive consumer group's information about the given topic in Zookeeper.

    zkUtils

    Zookeeper utilities

    topic

    Topic of the consumer group information we wish to delete

  20. def deleteConsumerGroupInZK(zkUtils: ZkUtils, group: String): Boolean

    Delete the whole directory of the given consumer group if the group is inactive.

    Delete the whole directory of the given consumer group if the group is inactive.

    zkUtils

    Zookeeper utilities

    group

    Consumer group

    returns

    whether or not we deleted the consumer group information

  21. def deleteConsumerGroupInfoForTopicInZK(zkUtils: ZkUtils, group: String, topic: String): Boolean

    Delete the given consumer group's information for the given topic in Zookeeper if the group is inactive.

    Delete the given consumer group's information for the given topic in Zookeeper if the group is inactive. If the consumer group consumes no other topics, delete the whole consumer group directory.

    zkUtils

    Zookeeper utilities

    group

    Consumer group

    topic

    Topic of the consumer group information we wish to delete

    returns

    whether or not we deleted the consumer group information for the given topic

  22. def deleteTopic(zkUtils: ZkUtils, topic: String): Unit

  23. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  24. def equals(arg0: Any): Boolean

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

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

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

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

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

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

    Definition Classes
    Logging
  31. def fetchAllEntityConfigs(zkUtils: ZkUtils, entityType: String): Map[String, Properties]

  32. def fetchAllTopicConfigs(zkUtils: ZkUtils): Map[String, Properties]

  33. def fetchEntityConfig(zkUtils: ZkUtils, entityType: String, entity: String): Properties

    Read the entity (topic or client) config (if any) from zk

  34. def fetchTopicMetadataFromZk(topics: Set[String], zkUtils: ZkUtils): Set[TopicMetadata]

  35. def fetchTopicMetadataFromZk(topic: String, zkUtils: ZkUtils): TopicMetadata

  36. def finalize(): Unit

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

    Definition Classes
    AnyRef → Any
  38. def getConfigChangeZnodeData(entityType: String, entityName: String): Map[String, Any]

  39. def getManualReplicaAssignment(replicaAssignmentList: String, availableBrokerList: Set[Int], startPartitionId: Int, checkBrokerAvailable: Boolean = true): Map[Int, List[Int]]

  40. def hashCode(): Int

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

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

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

    Definition Classes
    Logging
  44. def isConsumerGroupActive(zkUtils: ZkUtils, group: String): Boolean

  45. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  46. var logIdent: String

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

    Definition Classes
    Logging
  48. val loggerName: String

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

    Definition Classes
    AnyRef
  50. final def notify(): Unit

    Definition Classes
    AnyRef
  51. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  52. val rand: Random

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

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

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

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

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

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

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

    Definition Classes
    AnyRef
  60. def toString(): String

    Definition Classes
    AnyRef → Any
  61. def topicExists(zkUtils: ZkUtils, topic: String): Boolean

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

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

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

    Definition Classes
    Logging
  65. final def wait(): Unit

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

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

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

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

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

    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped