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(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

6. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

7. 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)

8. 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

9. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

10. def createOrUpdateTopicPartitionAssignmentPathInZK(zkClient: ZkClient, topic: String, partitionReplicaAssignment: Map[Int, Seq[Int]], config: Properties = new Properties, update: Boolean = false): Unit

    

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

    

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

    

    Definition Classes

    Logging

13. def debug(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

15. def deleteTopic(zkClient: ZkClient, 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: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

19. def error(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

20. def error(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

21. def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

22. def fatal(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

23. def fatal(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

24. def fetchAllTopicConfigs(zkClient: ZkClient): Map[String, Properties]

    

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

    

    Read the topic config (if any) from zk

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

    

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

    

28. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

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

    

31. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

32. def info(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

33. def info(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

34. def info(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

35. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

36. var logIdent: String

    

    Attributes

    protected

    Definition Classes

    Logging

37. lazy val logger: Logger

    

    Definition Classes

    Logging

38. val loggerName: String

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

40. final def notify(): Unit

    

    Definition Classes

    AnyRef

41. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

42. val rand: Random

    

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

    

    Definition Classes

    Logging

44. def swallowDebug(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

46. def swallowInfo(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

47. def swallowTrace(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

48. def swallowWarn(action: ⇒ Unit): Unit

    

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

50. def toString(): String

    

    Definition Classes

    AnyRef → Any

51. def topicExists(zkClient: ZkClient, topic: String): Boolean

    

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

    

    Definition Classes

    Logging

53. def trace(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

54. def trace(msg: ⇒ String): Unit

    

    Definition Classes

    Logging

55. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

58. def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

    

    Definition Classes

    Logging

59. def warn(e: ⇒ Throwable): Any

    

    Definition Classes

    Logging

60. def warn(msg: ⇒ String): Unit

    

    Definition Classes

    Logging