< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package actor
  Definition Classes
    manager
-  package base
  Definition Classes
    manager
-  package features
  Definition Classes
    manager
-  package jmx
  Definition Classes
    manager
-  package logkafka
  Definition Classes
    manager
-  package model
  Definition Classes
    manager
-  package utils

  Definition Classes
    manager
- ApiError
- BrokerListExtended
- ConsumerListExtended
- KafkaManager
- LogkafkaListExtended
- TopicListExtended

c

kafka.manager

# KafkaManager 

###
Companion object KafkaManager

#### class KafkaManager extends Logging

Linear Supertypes
Logging, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. KafkaManager
2. Logging
3. AnyRef
4. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new KafkaManager(akkaConfig: Config)

### 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
     @native() @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(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
12.  def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
13.  def debug(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
14.  val defaultTuning: ClusterTuning
15.  def deleteCluster(clusterName: String): Future[\/[ApiError, Unit]]
16.  def deleteLogkafka(clusterName: String, logkafka_id: String, log_path: String): Future[\/[ApiError, ClusterContext]]
17.  def deleteTopic(clusterName: String, topic: String): Future[\/[ApiError, ClusterContext]]
18.  def disableCluster(clusterName: String): Future[\/[ApiError, Unit]]
19.  def enableCluster(clusterName: String): Future[\/[ApiError, Unit]]
20.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
21.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
22.  def error(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
23.  def error(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
24.  def error(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
25.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
26.  def generatePartitionAssignments(clusterName: String, topics: Set[String], brokers: Set[Int], replicationFactor: Option[Int] = None): Future[\/[IndexedSeq[ApiError], Unit]]
27.  def getBrokerList(clusterName: String): Future[\/[ApiError, BrokerListExtended]]
28.  def getBrokerView(clusterName: String, brokerId: Int): Future[\/[ApiError, BVView]]
29.  def getBrokersView(clusterName: String): Future[\/[ApiError, Map[Int, BVView]]]
30.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
31.  def getClusterConfig(clusterName: String): Future[\/[ApiError, ClusterConfig]]
32.  def getClusterContext(clusterName: String): Future[\/[ApiError, ClusterContext]]
33.  def getClusterList: Future[\/[ApiError, KMClusterList]]
34.  def getClusterView(clusterName: String): Future[\/[ApiError, CMView]]
35.  def getConsumedTopicState(clusterName: String, consumer: String, topic: String, consumerType: String): Future[\/[ApiError, ConsumedTopicState]]
36.  def getConsumerIdentity(clusterName: String, consumer: String, consumerType: String): Future[\/[ApiError, ConsumerIdentity]]
37.  def getConsumerListExtended(clusterName: String): Future[\/[ApiError, ConsumerListExtended]]
38.  def getConsumersForTopic(clusterName: String, topic: String): Future[Option[Iterable[(String, ConsumerType)]]]
39.  def getGeneratedAssignments(clusterName: String, topic: String): Future[\/[ApiError, GeneratedPartitionAssignments]]
40.  def getLogkafkaIdentity(clusterName: String, logkafka_id: String): Future[\/[ApiError, LogkafkaIdentity]]
41.  def getLogkafkaListExtended(clusterName: String): Future[\/[ApiError, LogkafkaListExtended]]
42.  def getLogkafkaLogkafkaIdList(clusterName: String): Future[\/[ApiError, LogkafkaLogkafkaIdList]]
43.  def getPreferredLeaderElection(clusterName: String): Future[\/[ApiError, Option[PreferredReplicaElection]]]
44.  def getReassignPartitions(clusterName: String): Future[\/[ApiError, Option[ReassignPartitions]]]
45.  def getTopicIdentity(clusterName: String, topic: String): Future[\/[ApiError, TopicIdentity]]
46.  def getTopicList(clusterName: String): Future[\/[ApiError, TopicList]]
47.  def getTopicListExtended(clusterName: String): Future[\/[ApiError, TopicListExtended]]
48.  def getTopicMetrics(clusterName: String, topic: String): Future[\/[ApiError, Option[BrokerMetrics]]]
49.  def getTopicsUnderReassignment(clusterName: String): Future[\/[ApiError, IndexedSeq[String]]]
50.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
51.  def info(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
52.  def info(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
53.  def info(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
54.  def isDebugEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
55.  def isErrorEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
56.  def isInfoEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
57.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
58.  def isTraceEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
59.  def isWarnEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
60.  def logger: Logger
    Attributes
      protected
    Definition Classes
      Logging
61.  def loggerName: String
    Attributes
      protected
    Definition Classes
      Logging
62.  def manualPartitionAssignments(clusterName: String, assignments: List[(String, List[(Int, List[Int])])]): Future[\/[IndexedSeq[ApiError], Unit]]
63.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
64.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
65.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
66.  def runPreferredLeaderElection(clusterName: String, topics: Set[String]): Future[\/[ApiError, ClusterContext]]
67.  def runReassignPartitions(clusterName: String, topics: Set[String], force: Boolean = false): Future[\/[IndexedSeq[ApiError], Unit]]
68.  def shutdown(): Unit
69.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
70.  def toString(): String
    Definition Classes
      AnyRef → Any
71.  def topicListSortedByNumPartitions(tle: TopicListExtended): Seq[(String, Option[TopicIdentity])]
72.  def trace(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
73.  def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
74.  def trace(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
75.  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]]
76.  def updateLogkafkaConfig(clusterName: String, logkafka_id: String, log_path: String, config: Properties, checkConfig: Boolean = true): Future[\/[ApiError, ClusterContext]]
77.  def updateTopicConfig(clusterName: String, topic: String, config: Properties, readVersion: Int): Future[\/[ApiError, ClusterContext]]
78.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
79.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
80.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
81.  def warn(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
82.  def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
83.  def warn(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging

### Inherited from Logging

### Inherited from AnyRef

### Inherited from Any

### Ungrouped