model

Type Members

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
case class ClusterContext(clusterFeatures: ClusterFeatures, config: ClusterConfig) extends Product with Serializable
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
case class CuratorConfig(zkConnect: String, zkMaxRetry: Int = 100, baseSleepTimeMs: Int = 100, maxSleepTimeMs: Int = 1000) extends Product with Serializable
sealed trait KafkaVersion extends AnyRef
sealed trait SASLmechanism extends AnyRef
sealed trait SecurityProtocol extends AnyRef

Value Members

object ActorModel
object ClusterConfig extends Serializable
object ClusterTuning extends Serializable
object KafkaVersion
object Kafka_0_10_0_0 extends KafkaVersion with Product with Serializable
object Kafka_0_10_0_1 extends KafkaVersion with Product with Serializable
object Kafka_0_10_1_0 extends KafkaVersion with Product with Serializable
object Kafka_0_10_1_1 extends KafkaVersion with Product with Serializable
object Kafka_0_10_2_0 extends KafkaVersion with Product with Serializable
object Kafka_0_10_2_1 extends KafkaVersion with Product with Serializable
object Kafka_0_11_0_0 extends KafkaVersion with Product with Serializable
object Kafka_0_11_0_2 extends KafkaVersion with Product with Serializable
object Kafka_0_8_1_1 extends KafkaVersion with Product with Serializable
object Kafka_0_8_2_0 extends KafkaVersion with Product with Serializable
object Kafka_0_8_2_1 extends KafkaVersion with Product with Serializable
object Kafka_0_8_2_2 extends KafkaVersion with Product with Serializable
object Kafka_0_9_0_0 extends KafkaVersion with Product with Serializable
object Kafka_0_9_0_1 extends KafkaVersion with Product with Serializable
object Kafka_1_0_0 extends KafkaVersion with Product with Serializable
object Kafka_1_0_1 extends KafkaVersion with Product with Serializable
object Kafka_1_0_2 extends KafkaVersion with Product with Serializable
object Kafka_1_1_0 extends KafkaVersion with Product with Serializable
object Kafka_2_0_0 extends KafkaVersion with Product with Serializable
object PLAINTEXT extends SecurityProtocol with Product with Serializable
object SASL_MECHANISM_GSSAPI extends SASLmechanism with Product with Serializable
object SASL_MECHANISM_PLAIN extends SASLmechanism with Product with Serializable
object SASL_MECHANISM_SCRAM256 extends SASLmechanism with Product with Serializable
object SASL_MECHANISM_SCRAM512 extends SASLmechanism with Product with Serializable
object SASL_PLAINTEXT extends SecurityProtocol with Product with Serializable
object SASL_SSL extends SecurityProtocol with Product with Serializable
object SASLmechanism
object SSL extends SecurityProtocol with Product with Serializable
object SecurityProtocol
def fieldExtended[A](name: String)(json: JValue)(implicit arg0: org.json4s.scalaz.JsonScalaz.JSONR[A]): org.json4s.scalaz.JsonScalaz.Result[A]

package model

Type Members

case class ClusterContext(clusterFeatures: ClusterFeatures, config: ClusterConfig) extends Product with Serializable

case class CuratorConfig(zkConnect: String, zkMaxRetry: Int = 100, baseSleepTimeMs: Int = 100, maxSleepTimeMs: Int = 1000) extends Product with Serializable

sealed trait KafkaVersion extends AnyRef

sealed trait SASLmechanism extends AnyRef

sealed trait SecurityProtocol extends AnyRef

Value Members

object ActorModel

object ClusterConfig extends Serializable

object ClusterTuning extends Serializable

object KafkaVersion

object Kafka_0_10_0_0 extends KafkaVersion with Product with Serializable

object Kafka_0_10_0_1 extends KafkaVersion with Product with Serializable

object Kafka_0_10_1_0 extends KafkaVersion with Product with Serializable

object Kafka_0_10_1_1 extends KafkaVersion with Product with Serializable

object Kafka_0_10_2_0 extends KafkaVersion with Product with Serializable

object Kafka_0_10_2_1 extends KafkaVersion with Product with Serializable

object Kafka_0_11_0_0 extends KafkaVersion with Product with Serializable

object Kafka_0_11_0_2 extends KafkaVersion with Product with Serializable

object Kafka_0_8_1_1 extends KafkaVersion with Product with Serializable

object Kafka_0_8_2_0 extends KafkaVersion with Product with Serializable

object Kafka_0_8_2_1 extends KafkaVersion with Product with Serializable

object Kafka_0_8_2_2 extends KafkaVersion with Product with Serializable

object Kafka_0_9_0_0 extends KafkaVersion with Product with Serializable

object Kafka_0_9_0_1 extends KafkaVersion with Product with Serializable

object Kafka_1_0_0 extends KafkaVersion with Product with Serializable

object Kafka_1_0_1 extends KafkaVersion with Product with Serializable

object Kafka_1_0_2 extends KafkaVersion with Product with Serializable

object Kafka_1_1_0 extends KafkaVersion with Product with Serializable

object Kafka_2_0_0 extends KafkaVersion with Product with Serializable

object PLAINTEXT extends SecurityProtocol with Product with Serializable

object SASL_MECHANISM_GSSAPI extends SASLmechanism with Product with Serializable

object SASL_MECHANISM_PLAIN extends SASLmechanism with Product with Serializable

object SASL_MECHANISM_SCRAM256 extends SASLmechanism with Product with Serializable

object SASL_MECHANISM_SCRAM512 extends SASLmechanism with Product with Serializable

object SASL_PLAINTEXT extends SecurityProtocol with Product with Serializable

object SASL_SSL extends SecurityProtocol with Product with Serializable

object SASLmechanism

object SSL extends SecurityProtocol with Product with Serializable

object SecurityProtocol

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

Inherited from AnyRef

Inherited from Any

Ungrouped