< 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
- ActorModel
- ClusterConfig
- ClusterContext
- ClusterTuning
- CuratorConfig
- KafkaVersion
- Kafka_0_10_0_0
- Kafka_0_10_0_1
- Kafka_0_10_1_0
- Kafka_0_10_1_1
- Kafka_0_10_2_0
- Kafka_0_10_2_1
- Kafka_0_11_0_0
- Kafka_0_11_0_2
- Kafka_0_8_1_1
- Kafka_0_8_2_0
- Kafka_0_8_2_1
- Kafka_0_8_2_2
- Kafka_0_9_0_0
- Kafka_0_9_0_1
- Kafka_1_0_0
- Kafka_1_0_1
- Kafka_1_1_0
- Kafka_1_1_1
- Kafka_2_0_0
- Kafka_2_1_0
- Kafka_2_1_1
- Kafka_2_2_0
- PLAINTEXT
- PLAINTEXTSASL
- SASL_MECHANISM_GSSAPI
- SASL_MECHANISM_PLAIN
- SASL_MECHANISM_SCRAM256
- SASL_MECHANISM_SCRAM512
- SASL_PLAINTEXT
- SASL_SSL
- SASLmechanism
- SSL
- SecurityProtocol
-  package utils

  Definition Classes
    manager

p

kafka.manager

# model 

#### package model

Linear Supertypes
AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. model
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Type Members

1.  case class ClusterConfig(name: String, curatorConfig: CuratorConfig, enabled: Boolean, version: KafkaVersion, jmxEnabled: Boolean, jmxUser: Option[String], jmxPass: Option[String], jmxSsl: Boolean, pollConsumers: Boolean, filterConsumers: Boolean, logkafkaEnabled: Boolean, activeOffsetCacheEnabled: Boolean, displaySizeEnabled: Boolean, tuning: Option[ClusterTuning], securityProtocol: SecurityProtocol, saslMechanism: Option[SASLmechanism], jaasConfig: Option[String]) extends Product with Serializable
2.  case class ClusterContext(clusterFeatures: ClusterFeatures, config: ClusterConfig) extends Product with Serializable
3.  case class ClusterTuning(brokerViewUpdatePeriodSeconds: Option[Int], clusterManagerThreadPoolSize: Option[Int], clusterManagerThreadPoolQueueSize: Option[Int], kafkaCommandThreadPoolSize: Option[Int], kafkaCommandThreadPoolQueueSize: Option[Int], logkafkaCommandThreadPoolSize: Option[Int], logkafkaCommandThreadPoolQueueSize: Option[Int], logkafkaUpdatePeriodSeconds: Option[Int], partitionOffsetCacheTimeoutSecs: Option[Int], brokerViewThreadPoolSize: Option[Int], brokerViewThreadPoolQueueSize: Option[Int], offsetCacheThreadPoolSize: Option[Int], offsetCacheThreadPoolQueueSize: Option[Int], kafkaAdminClientThreadPoolSize: Option[Int], kafkaAdminClientThreadPoolQueueSize: Option[Int], kafkaManagedOffsetMetadataCheckMillis: Option[Int], kafkaManagedOffsetGroupCacheSize: Option[Int], kafkaManagedOffsetGroupExpireDays: Option[Int]) extends Product with Serializable
4.  case class CuratorConfig(zkConnect: String, zkMaxRetry: Int = 100, baseSleepTimeMs: Int = 100, maxSleepTimeMs: Int = 1000) extends Product with Serializable

5.  sealed trait KafkaVersion extends AnyRef
6.  sealed trait SASLmechanism extends AnyRef
7.  sealed trait SecurityProtocol extends AnyRef

### Value Members

1.  def fieldExtended[A](name: String)(json: JValue)(implicit arg0: org.json4s.scalaz.JsonScalaz.JSONR[A]): org.json4s.scalaz.JsonScalaz.Result[A]
2.  object ActorModel

3.  object ClusterConfig extends Serializable
4.  object ClusterTuning extends Serializable
5.  object KafkaVersion
6.  object Kafka_0_10_0_0 extends KafkaVersion with Product with Serializable
7.  object Kafka_0_10_0_1 extends KafkaVersion with Product with Serializable
8.  object Kafka_0_10_1_0 extends KafkaVersion with Product with Serializable
9.  object Kafka_0_10_1_1 extends KafkaVersion with Product with Serializable
10.  object Kafka_0_10_2_0 extends KafkaVersion with Product with Serializable
11.  object Kafka_0_10_2_1 extends KafkaVersion with Product with Serializable
12.  object Kafka_0_11_0_0 extends KafkaVersion with Product with Serializable
13.  object Kafka_0_11_0_2 extends KafkaVersion with Product with Serializable
14.  object Kafka_0_8_1_1 extends KafkaVersion with Product with Serializable
15.  object Kafka_0_8_2_0 extends KafkaVersion with Product with Serializable
16.  object Kafka_0_8_2_1 extends KafkaVersion with Product with Serializable
17.  object Kafka_0_8_2_2 extends KafkaVersion with Product with Serializable
18.  object Kafka_0_9_0_0 extends KafkaVersion with Product with Serializable
19.  object Kafka_0_9_0_1 extends KafkaVersion with Product with Serializable
20.  object Kafka_1_0_0 extends KafkaVersion with Product with Serializable
21.  object Kafka_1_0_1 extends KafkaVersion with Product with Serializable
22.  object Kafka_1_1_0 extends KafkaVersion with Product with Serializable
23.  object Kafka_1_1_1 extends KafkaVersion with Product with Serializable
24.  object Kafka_2_0_0 extends KafkaVersion with Product with Serializable
25.  object Kafka_2_1_0 extends KafkaVersion with Product with Serializable
26.  object Kafka_2_1_1 extends KafkaVersion with Product with Serializable
27.  object Kafka_2_2_0 extends KafkaVersion with Product with Serializable
28.  object PLAINTEXT extends SecurityProtocol with Product with Serializable
29.  object PLAINTEXTSASL extends SecurityProtocol with Product with Serializable
30.  object SASL_MECHANISM_GSSAPI extends SASLmechanism with Product with Serializable
31.  object SASL_MECHANISM_PLAIN extends SASLmechanism with Product with Serializable
32.  object SASL_MECHANISM_SCRAM256 extends SASLmechanism with Product with Serializable
33.  object SASL_MECHANISM_SCRAM512 extends SASLmechanism with Product with Serializable
34.  object SASL_PLAINTEXT extends SecurityProtocol with Product with Serializable
35.  object SASL_SSL extends SecurityProtocol with Product with Serializable
36.  object SASLmechanism
37.  object SSL extends SecurityProtocol with Product with Serializable
38.  object SecurityProtocol

### Inherited from AnyRef

### Inherited from Any

### Ungrouped