< Back
 

# Packages

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

  Definition Classes
    kafka
-  package actor
  Definition Classes
    manager
-  package cluster

  Created by hiral on 12/1/15.

  Created by hiral on 12/1/15.

  Definition Classes
    actor
- DeleteClusterActor
- DeleteClusterActorConfig
- KafkaManagerActor
- KafkaManagerActorConfig

c

kafka.manager.actor

# KafkaManagerActorConfig 

###

#### case class KafkaManagerActorConfig(curatorConfig: CuratorConfig, baseZkPath: String = KafkaManagerActor.ZkRoot, pinnedDispatcherName: String = "pinned-dispatcher", startDelayMillis: Long = 1000, threadPoolSize: Int = 2, mutexTimeoutMillis: Int = 4000, maxQueueSize: Int = 100, kafkaManagerUpdatePeriod: FiniteDuration = 10 seconds, deleteClusterUpdatePeriod: FiniteDuration = 10 seconds, deletionBatchSize: Int = 2, clusterActorsAskTimeoutMillis: Int = 2000, simpleConsumerSocketTimeoutMillis: Int = 10000, defaultTuning: ClusterTuning, consumerProperties: Option[Properties]) extends Product with Serializable

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. KafkaManagerActorConfig
2. Serializable
3. Serializable
4. Product
5. Equals
6. AnyRef
7. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new KafkaManagerActorConfig(curatorConfig: CuratorConfig, baseZkPath: String = KafkaManagerActor.ZkRoot, pinnedDispatcherName: String = "pinned-dispatcher", startDelayMillis: Long = 1000, threadPoolSize: Int = 2, mutexTimeoutMillis: Int = 4000, maxQueueSize: Int = 100, kafkaManagerUpdatePeriod: FiniteDuration = 10 seconds, deleteClusterUpdatePeriod: FiniteDuration = 10 seconds, deletionBatchSize: Int = 2, clusterActorsAskTimeoutMillis: Int = 2000, simpleConsumerSocketTimeoutMillis: Int = 10000, defaultTuning: ClusterTuning, consumerProperties: Option[Properties])

### 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.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
5.  val baseZkPath: String
6.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
7.  val clusterActorsAskTimeoutMillis: Int
8.  val consumerProperties: Option[Properties]
9.  val curatorConfig: CuratorConfig
10.  val defaultTuning: ClusterTuning
11.  val deleteClusterUpdatePeriod: FiniteDuration
12.  val deletionBatchSize: Int
13.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
14.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
15.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
16.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
17.  val kafkaManagerUpdatePeriod: FiniteDuration
18.  val maxQueueSize: Int
19.  val mutexTimeoutMillis: Int
20.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
21.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
22.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
23.  val pinnedDispatcherName: String
24.  val simpleConsumerSocketTimeoutMillis: Int
25.  val startDelayMillis: Long
26.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
27.  val threadPoolSize: Int
28.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
29.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
30.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from Serializable

### Inherited from Product

### Inherited from Equals

### Inherited from AnyRef

### Inherited from Any

### Ungrouped