Object/Class

kafka.utils

ZkUtils

Related Docs: class ZkUtils | package utils

Permalink

object ZkUtils

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ZkUtils
  2. AnyRef
  3. 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 BrokerIdsPath: String

    Permalink
  5. val BrokerSequenceIdPath: String

    Permalink
  6. val BrokerTopicsPath: String

    Permalink
  7. val ConsumersPath: String

    Permalink
  8. val ControllerEpochPath: String

    Permalink
  9. val ControllerPath: String

    Permalink
  10. def DefaultAcls(isSecure: Boolean): List[ACL]

    Permalink
  11. val DeleteTopicsPath: String

    Permalink
  12. val EntityConfigChangesPath: String

    Permalink
  13. val EntityConfigPath: String

    Permalink
  14. val IsrChangeNotificationPath: String

    Permalink
  15. val PreferredReplicaLeaderElectionPath: String

    Permalink
  16. val ReassignPartitionsPath: String

    Permalink
  17. def apply(zkClient: ZkClient, isZkSecurityEnabled: Boolean): ZkUtils

    Permalink
  18. def apply(zkUrl: String, sessionTimeout: Int, connectionTimeout: Int, isZkSecurityEnabled: Boolean): ZkUtils

    Permalink
  19. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  20. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. def createZkClient(zkUrl: String, sessionTimeout: Int, connectionTimeout: Int): ZkClient

    Permalink
  22. def createZkClientAndConnection(zkUrl: String, sessionTimeout: Int, connectionTimeout: Int): (ZkClient, ZkConnection)

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

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

    Permalink
    Definition Classes
    AnyRef → Any
  25. def finalize(): Unit

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

    Permalink
    Definition Classes
    AnyRef → Any
  27. def getDeleteTopicPath(topic: String): String

    Permalink
  28. def getEntityConfigPath(entityType: String, entity: String): String

    Permalink
  29. def getEntityConfigRootPath(entityType: String): String

    Permalink
  30. def getTopicPartitionLeaderAndIsrPath(topic: String, partitionId: Int): String

    Permalink
  31. def getTopicPartitionPath(topic: String, partitionId: Int): String

    Permalink
  32. def getTopicPartitionsPath(topic: String): String

    Permalink
  33. def getTopicPath(topic: String): String

    Permalink
  34. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  35. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  36. def maybeDeletePath(zkUrl: String, dir: String): Unit

    Permalink
  37. final def ne(arg0: AnyRef): Boolean

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

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

    Permalink
    Definition Classes
    AnyRef
  40. final def synchronized[T0](arg0: ⇒ T0): T0

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

    Permalink
    Definition Classes
    AnyRef → Any
  42. final def wait(): Unit

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

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped