< 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
- BrokerViewCacheActor
- BrokerViewCacheActorConfig
- ClusterManagerActor
- ClusterManagerActorConfig
- ConsumerInstanceSubscriptions
- KafkaAdminClient
- KafkaAdminClientActor
- KafkaAdminClientActorConfig
- KafkaCommandActor
- KafkaCommandActorConfig
- KafkaManagedOffsetCache
- KafkaManagedOffsetCacheConfig
- KafkaStateActor
- KafkaStateActorConfig
- OffsetCache
- OffsetCacheActive
- OffsetCachePassive
- PartitionOffsetRequestInfo
- TryLogErrorHelper

p

kafka.manager.actor

# cluster 

#### package cluster

Created by hiral on 12/1/15.

Linear Supertypes
AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. cluster
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Type Members

1.  class BrokerViewCacheActor extends BaseActor with LongRunningPoolActor with BaseClusterActor
2.  case class BrokerViewCacheActorConfig(kafkaStateActorPath: ActorPath, clusterContext: ClusterContext, longRunningPoolConfig: LongRunningPoolConfig, updatePeriod: FiniteDuration = 10 seconds) extends Product with Serializable
3.  class ClusterManagerActor extends BaseClusterQueryCommandActor with CuratorAwareActor with BaseZkPath
4.  case class ClusterManagerActorConfig(pinnedDispatcherName: String, baseZkPath: String, curatorConfig: CuratorConfig, clusterConfig: ClusterConfig, consumerProperties: Option[Properties], askTimeoutMillis: Long = 2000, mutexTimeoutMillis: Int = 4000, simpleConsumerSocketTimeoutMillis: Int = 10000) extends Product with Serializable
5.  case class ConsumerInstanceSubscriptions extends Product with Serializable
6.  class KafkaAdminClient extends AnyRef
7.  case class KafkaAdminClientActor(config: KafkaAdminClientActorConfig) extends BaseClusterQueryActor with LongRunningPoolActor with Product with Serializable
8.  case class KafkaAdminClientActorConfig(clusterContext: ClusterContext, longRunningPoolConfig: LongRunningPoolConfig, kafkaStateActorPath: ActorPath, consumerProperties: Option[Properties]) extends Product with Serializable
9.  class KafkaCommandActor extends BaseClusterCommandActor with LongRunningPoolActor
10.  case class KafkaCommandActorConfig(curator: CuratorFramework, longRunningPoolConfig: LongRunningPoolConfig, askTimeoutMillis: Long = 400, clusterContext: ClusterContext, adminUtils: AdminUtils) extends Product with Serializable

11.  case class KafkaManagedOffsetCache(clusterContext: ClusterContext, adminClient: KafkaAdminClient, consumerProperties: Option[Properties], bootstrapBrokerList: BrokerList, config: KafkaManagedOffsetCacheConfig) extends Runnable with Closeable with Logging with Product with Serializable
12.  case class KafkaManagedOffsetCacheConfig(groupMemberMetadataCheckMillis: Int = ..., groupTopicPartitionOffsetMaxSize: Int = ..., groupTopicPartitionOffsetExpireDays: Int = ...) extends Product with Serializable
13.  class KafkaStateActor extends BaseClusterQueryCommandActor with LongRunningPoolActor
14.  case class KafkaStateActorConfig(curator: CuratorFramework, pinnedDispatcherName: String, clusterContext: ClusterContext, offsetCachePoolConfig: LongRunningPoolConfig, kafkaAdminClientPoolConfig: LongRunningPoolConfig, partitionOffsetCacheTimeoutSecs: Int, simpleConsumerSocketTimeoutMillis: Int, consumerProperties: Option[Properties], kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig) extends Product with Serializable
15.  trait OffsetCache extends Logging
16.  case class OffsetCacheActive(curator: CuratorFramework, kafkaAdminClient: KafkaAdminClient, clusterContext: ClusterContext, partitionLeaders: (String) ⇒ Option[List[(Int, Option[BrokerIdentity])]], topicDescriptions: (String, Boolean) ⇒ Option[TopicDescription], cacheTimeoutSecs: Int, socketTimeoutMillis: Int, kafkaVersion: KafkaVersion, consumerProperties: Option[Properties], kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig, getBrokerList: () ⇒ BrokerList)(implicit ec: ExecutionContext, cf: ClusterFeatures) extends OffsetCache with Product with Serializable
17.  case class OffsetCachePassive(curator: CuratorFramework, kafkaAdminClient: KafkaAdminClient, clusterContext: ClusterContext, partitionLeaders: (String) ⇒ Option[List[(Int, Option[BrokerIdentity])]], topicDescriptions: (String, Boolean) ⇒ Option[TopicDescription], cacheTimeoutSecs: Int, socketTimeoutMillis: Int, kafkaVersion: KafkaVersion, consumerProperties: Option[Properties], kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig, getBrokerList: () ⇒ BrokerList)(implicit ec: ExecutionContext, cf: ClusterFeatures) extends OffsetCache with Product with Serializable
18.  case class PartitionOffsetRequestInfo(time: Long, maxNumOffsets: Int) extends Product with Serializable
19.  implicit class TryLogErrorHelper[T] extends Logging

### Value Members

1.  def featureGate[T](af: ClusterFeature, af2: ClusterFeature, af3: ClusterFeature)(fn: ⇒ Unit)(implicit features: ClusterFeatures): Unit
2.  def featureGate[T](af: ClusterFeature, af2: ClusterFeature)(fn: ⇒ Unit)(implicit features: ClusterFeatures): Unit
3.  def featureGate[T](af: ClusterFeature)(fn: ⇒ Unit)(implicit features: ClusterFeatures): Unit
4.  def featureGateFold[T](af: ClusterFeature)(elseFn: ⇒ T, fn: ⇒ T)(implicit features: ClusterFeatures): T
5.  implicit def toBiConsumer[A, B](fn: (A, B) ⇒ Unit): BiConsumer[A, B]
6.  object ClusterManagerActor

7.  object ConsumerInstanceSubscriptions extends Logging with Serializable
8.  object KafkaManagedOffsetCache extends Serializable
9.  object KafkaManagedOffsetCacheConfig extends Serializable

### Inherited from AnyRef

### Inherited from Any

### Ungrouped