KafkaManager

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. def addCluster(clusterName: String, version: String, zkHosts: String, jmxEnabled: Boolean, jmxUser: Option[String], jmxPass: Option[String], jmxSsl: Boolean, pollConsumers: Boolean, filterConsumers: Boolean, tuning: Option[ClusterTuning], securityProtocol: String, saslMechanism: Option[String], jaasConfig: Option[String], logkafkaEnabled: Boolean = false, activeOffsetCacheEnabled: Boolean = false, displaySizeEnabled: Boolean = false): Future[\/[ApiError, Unit]]

   

5. def addMultipleTopicsPartitions(clusterName: String, topics: Seq[String], brokers: Set[Int], partitions: Int, readVersions: Map[String, Int]): Future[\/[ApiError, ClusterContext]]

   

6. def addTopicPartitions(clusterName: String, topic: String, brokers: Seq[Int], partitions: Int, readVersion: Int): Future[\/[ApiError, ClusterContext]]

   

7. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. def createLogkafka(clusterName: String, logkafka_id: String, log_path: String, config: Properties = new Properties): Future[\/[ApiError, ClusterContext]]

   

10. def createTopic(clusterName: String, topic: String, partitions: Int, replication: Int, config: Properties = new Properties): Future[\/[ApiError, ClusterContext]]

    

11. def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

13. val defaultTuning: ClusterTuning

    

14. def deleteCluster(clusterName: String): Future[\/[ApiError, Unit]]

    

15. def deleteLogkafka(clusterName: String, logkafka_id: String, log_path: String): Future[\/[ApiError, ClusterContext]]

    

16. def deleteTopic(clusterName: String, topic: String): Future[\/[ApiError, ClusterContext]]

    

17. def disableCluster(clusterName: String): Future[\/[ApiError, Unit]]

    

18. def enableCluster(clusterName: String): Future[\/[ApiError, Unit]]

    

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

    

    Definition Classes

    AnyRef

20. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

23. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

24. def generatePartitionAssignments(clusterName: String, topics: Set[String], brokers: Set[Int]): Future[\/[IndexedSeq[ApiError], Unit]]

    

25. def getBrokerList(clusterName: String): Future[\/[ApiError, BrokerListExtended]]

    

26. def getBrokerView(clusterName: String, brokerId: Int): Future[\/[ApiError, BVView]]

    

27. def getBrokersView(clusterName: String): Future[\/[ApiError, Map[Int, BVView]]]

    

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

    

    Definition Classes

    AnyRef → Any

29. def getClusterConfig(clusterName: String): Future[\/[ApiError, ClusterConfig]]

    

30. def getClusterContext(clusterName: String): Future[\/[ApiError, ClusterContext]]

    

31. def getClusterList: Future[\/[ApiError, KMClusterList]]

    

32. def getClusterView(clusterName: String): Future[\/[ApiError, CMView]]

    

33. def getConsumedTopicState(clusterName: String, consumer: String, topic: String, consumerType: String): Future[\/[ApiError, ConsumedTopicState]]

    

34. def getConsumerIdentity(clusterName: String, consumer: String, consumerType: String): Future[\/[ApiError, ConsumerIdentity]]

    

35. def getConsumerListExtended(clusterName: String): Future[\/[ApiError, ConsumerListExtended]]

    

36. def getConsumersForTopic(clusterName: String, topic: String): Future[Option[Iterable[(String, ConsumerType)]]]

    

37. def getGeneratedAssignments(clusterName: String, topic: String): Future[\/[ApiError, GeneratedPartitionAssignments]]

    

38. def getLogkafkaIdentity(clusterName: String, logkafka_id: String): Future[\/[ApiError, LogkafkaIdentity]]

    

39. def getLogkafkaListExtended(clusterName: String): Future[\/[ApiError, LogkafkaListExtended]]

    

40. def getLogkafkaLogkafkaIdList(clusterName: String): Future[\/[ApiError, LogkafkaLogkafkaIdList]]

    

41. def getPreferredLeaderElection(clusterName: String): Future[\/[ApiError, Option[PreferredReplicaElection]]]

    

42. def getReassignPartitions(clusterName: String): Future[\/[ApiError, Option[ReassignPartitions]]]

    

43. def getTopicIdentity(clusterName: String, topic: String): Future[\/[ApiError, TopicIdentity]]

    

44. def getTopicList(clusterName: String): Future[\/[ApiError, TopicList]]

    

45. def getTopicListExtended(clusterName: String): Future[\/[ApiError, TopicListExtended]]

    

46. def getTopicMetrics(clusterName: String, topic: String): Future[\/[ApiError, Option[BrokerMetrics]]]

    

47. def getTopicsUnderReassignment(clusterName: String): Future[\/[ApiError, IndexedSeq[String]]]

    

48. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

51. def isDebugEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

52. def isErrorEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

53. def isInfoEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

54. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

55. def isTraceEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

56. def isWarnEnabled: Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

57. def logger: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

58. def loggerName: String

    

    Attributes

    protected

    Definition Classes

    Logging

59. def manualPartitionAssignments(clusterName: String, assignments: List[(String, List[(Int, List[Int])])]): Future[\/[IndexedSeq[ApiError], Unit]]

    

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

    

    Definition Classes

    AnyRef

61. final def notify(): Unit

    

    Definition Classes

    AnyRef

62. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

63. def runPreferredLeaderElection(clusterName: String, topics: Set[String]): Future[\/[ApiError, ClusterContext]]

    

64. def runReassignPartitions(clusterName: String, topics: Set[String], force: Boolean = false): Future[\/[IndexedSeq[ApiError], Unit]]

    

65. def shutdown(): Unit

    

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

    

    Definition Classes

    AnyRef

67. def toString(): String

    

    Definition Classes

    AnyRef → Any

68. def topicListSortedByNumPartitions(tle: TopicListExtended): Seq[(String, Option[TopicIdentity])]

    

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

71. def updateCluster(clusterName: String, version: String, zkHosts: String, jmxEnabled: Boolean, jmxUser: Option[String], jmxPass: Option[String], jmxSsl: Boolean, pollConsumers: Boolean, filterConsumers: Boolean, tuning: Option[ClusterTuning], securityProtocol: String, saslMechanism: Option[String], jaasConfig: Option[String], logkafkaEnabled: Boolean = false, activeOffsetCacheEnabled: Boolean = false, displaySizeEnabled: Boolean = false): Future[\/[ApiError, Unit]]

    

72. def updateLogkafkaConfig(clusterName: String, logkafka_id: String, log_path: String, config: Properties, checkConfig: Boolean = true): Future[\/[ApiError, ClusterContext]]

    

73. def updateTopicConfig(clusterName: String, topic: String, config: Properties, readVersion: Int): Future[\/[ApiError, ClusterContext]]

    

74. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging