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

- DeleteClusterActor
- DeleteClusterActorConfig
- KafkaManagerActor
- KafkaManagerActorConfig
-  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

p

kafka.manager

# actor 

#### package actor

 
Ordering

1. Alphabetic

Visibility

1. Public
2. All

### Type Members

1.  class DeleteClusterActor extends BaseCommandActor
2.  case class DeleteClusterActorConfig(curator: CuratorFramework, baseDeleteClustersZKPath: String, baseClustersZKPath: String, baseConfigsZKPath: String, updatePeriod: FiniteDuration = 10 seconds, deletionBatchSize: Int = 2) extends Product with Serializable

3.  class KafkaManagerActor extends BaseQueryCommandActor with CuratorAwareActor with BaseZkPath
4.  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

### Value Members

1.  object KafkaManagerActor

### Ungrouped