AdminUtils

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

    @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(msg: ⇒ Any, t: ⇒ Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

14. def debug(msg: ⇒ Any): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

15. def deleteTopic(curator: CuratorFramework, topic: String): Unit

    

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

    

    Definition Classes

    AnyRef

17. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

18. def error(msg: ⇒ Any, t: ⇒ Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

19. def error(msg: ⇒ Any): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

20. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

22. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

23. def info(msg: ⇒ Any, t: ⇒ Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

24. def info(msg: ⇒ Any): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

25. def isDebugEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

26. def isErrorEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

27. def isInfoEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

28. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

29. def isTraceEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

30. def isWarnEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

31. def logger: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

32. def loggerName: String

    

    Attributes

    protected

    Definition Classes

    Logging

33. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

34. final def notify(): Unit

    

    Definition Classes

    AnyRef

35. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

36. val rand: Random

    

37. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

38. def toString(): String

    

    Definition Classes

    AnyRef → Any

39. def topicExists(curator: CuratorFramework, topic: String): Boolean

    

40. def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

41. def trace(msg: ⇒ Any): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

42. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

45. def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

46. def warn(msg: ⇒ Any): Unit

    

    Attributes

    protected

    Definition Classes

    Logging