Object

kafka.admin

AdminUtils

Related Doc: package admin

Permalink

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
Visibility
  1. Public
  2. All

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

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

    Permalink
    Definition Classes
    AnyRef → Any
  4. val AdminClientId: String

    Permalink
  5. val EntityConfigChangeZnodePrefix: String

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

    Permalink

    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

  7. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  8. def assignReplicasToBrokers(brokerList: Seq[Int], nPartitions: Int, replicationFactor: Int, fixedStartIndex: Int = 1, startPartitionId: Int = 1): Map[Int, Seq[Int]]

    Permalink

    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 changeClientIdConfig(zkUtils: ZkUtils, clientId: String, configs: Properties): Unit

    Permalink

    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

  10. def changeTopicConfig(zkUtils: ZkUtils, topic: String, configs: Properties): Unit

    Permalink

    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

  11. def clone(): AnyRef

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

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

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

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

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

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

    Permalink

    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

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

    Permalink

    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

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

    Permalink

    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

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

    Permalink
  21. final def eq(arg0: AnyRef): Boolean

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

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

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

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

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

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

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

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

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

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

    Permalink

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

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

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

    Permalink
  34. def finalize(): Unit

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

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

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

    Permalink
  38. def hashCode(): Int

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

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

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

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

    Permalink
  43. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  44. var logIdent: String

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  45. lazy val logger: Logger

    Permalink
    Definition Classes
    Logging
  46. val loggerName: String

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

    Permalink
    Definition Classes
    AnyRef
  48. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  49. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  50. val rand: Random

    Permalink
  51. def swallow(action: ⇒ Unit): Unit

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

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

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

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

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

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

    Permalink
    Definition Classes
    AnyRef
  58. def toString(): String

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

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

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

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

    Permalink
    Definition Classes
    Logging
  63. final def wait(): Unit

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

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

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

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

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

    Permalink
    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped