AdminUtils

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 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. final def asInstanceOf[T0]: T0

   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[java.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. final def eq(arg0: AnyRef): Boolean

    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[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

31. final def getClass(): Class[_]

    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. final def isInstanceOf[T0]: Boolean

    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. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

42. final def notify(): Unit

    Definition Classes

    AnyRef

43. final def notifyAll(): Unit

    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. final def synchronized[T0](arg0: ⇒ T0): T0

    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. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

58. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

59. final def wait(arg0: Long): Unit

    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