< 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

c

kafka.manager.actor.cluster

# OffsetCachePassive 

###

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

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

1. Alphabetic
2. By Inheritance

Inherited

1. OffsetCachePassive
2. Serializable
3. Serializable
4. Product
5. Equals
6. OffsetCache
7. Logging
8. AnyRef
9. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new 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)

### 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 cacheTimeoutSecs: Int
6.  implicit val cf: ClusterFeatures
   Definition Classes
     OffsetCachePassive → OffsetCache
7.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
8.  val clusterContext: ClusterContext
   Definition Classes
     OffsetCachePassive → OffsetCache
9.  val consumerProperties: Option[Properties]
   Definition Classes
     OffsetCachePassive → OffsetCache
10.  val curator: CuratorFramework
11.  def debug(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
12.  def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
13.  def debug(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
14.  implicit val ec: ExecutionContext
    Attributes
      protected[this]
    Definition Classes
      OffsetCachePassive → OffsetCache
15.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
16.  def error(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
17.  def error(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
18.  def error(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
19.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
20.  val getBrokerList: () ⇒ BrokerList
    Definition Classes
      OffsetCachePassive → OffsetCache
21.  def getCacheTimeoutSecs: Int
    Definition Classes
      OffsetCachePassive → OffsetCache
22.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
23.  final def getConsumedTopicDescription(consumer: String, topic: String, interactive: Boolean, consumerType: ConsumerType): ConsumedTopicDescription
    Definition Classes
      OffsetCache
24.  final def getConsumerDescription(consumer: String, consumerType: ConsumerType): ConsumerDescription
    Definition Classes
      OffsetCache
25.  final def getConsumerList: ConsumerList
    Definition Classes
      OffsetCache
26.  def getConsumerTopics(consumer: String): Set[String]
    Attributes
      protected
    Definition Classes
      OffsetCache
27.  def getConsumerTopicsFromIds(consumer: String): Set[String]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
28.  def getConsumerTopicsFromOffsets(consumer: String): Set[String]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
29.  def getConsumerTopicsFromOwners(consumer: String): Set[String]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
30.  def getKafkaManagedConsumerList: IndexedSeq[ConsumerNameAndType]
    Attributes
      protected
    Definition Classes
      OffsetCache
31.  def getKafkaManagedConsumerTopics(consumer: String): Set[String]
    Attributes
      protected
    Definition Classes
      OffsetCache
32.  def getKafkaVersion: KafkaVersion
    Definition Classes
      OffsetCachePassive → OffsetCache
33.  def getSimpleConsumerSocketTimeoutMillis: Int
    Definition Classes
      OffsetCachePassive → OffsetCache
34.  def getTopicDescription(topic: String, interactive: Boolean): Option[TopicDescription]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
35.  def getTopicPartitionLeaders(topic: String): Option[List[(Int, Option[BrokerIdentity])]]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
36.  def getTopicPartitionOffsets(topic: String, interactive: Boolean): Future[PartitionOffsetsCapture]
    Definition Classes
      OffsetCache
37.  def getZKManagedConsumerList: IndexedSeq[ConsumerNameAndType]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
38.  def info(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
39.  def info(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
40.  def info(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
41.  def isDebugEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
42.  def isErrorEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
43.  def isInfoEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
44.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
45.  def isTraceEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
46.  def isWarnEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
47.  val kafkaAdminClient: KafkaAdminClient
    Definition Classes
      OffsetCachePassive → OffsetCache
48.  val kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig
    Definition Classes
      OffsetCachePassive → OffsetCache
49.  val kafkaVersion: KafkaVersion
50.  final def lastUpdateMillis: Long
    Definition Classes
      OffsetCache
51.  def lastUpdateMillisZK: Long
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
52.  val loadOffsets: Boolean
    Definition Classes
      OffsetCachePassive → OffsetCache
53.  def logger: Logger
    Attributes
      protected
    Definition Classes
      Logging
54.  def loggerName: String
    Attributes
      protected
    Definition Classes
      Logging
55.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
56.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
57.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
58.  val partitionLeaders: (String) ⇒ Option[List[(Int, Option[BrokerIdentity])]]
59.  def readConsumerOffsetByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, Long]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
60.  def readConsumerOwnerByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, String]
    Attributes
      protected
    Definition Classes
      OffsetCachePassive → OffsetCache
61.  def readKafkaManagedConsumerOffsetByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, Long]
    Attributes
      protected
    Definition Classes
      OffsetCache
62.  def readKafkaManagedConsumerOwnerByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, String]
    Attributes
      protected
    Definition Classes
      OffsetCache
63.  val socketTimeoutMillis: Int
64.  def start(): Unit
    Definition Classes
      OffsetCachePassive → OffsetCache
65.  def stop(): Unit
    Definition Classes
      OffsetCachePassive → OffsetCache
66.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
67.  val topicDescriptions: (String, Boolean) ⇒ Option[TopicDescription]
68.  def trace(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
69.  def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
70.  def trace(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
71.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
72.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
73.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
74.  def warn(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
75.  def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
76.  def warn(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging

### Inherited from Serializable

### Inherited from Product

### Inherited from Equals

### Inherited from OffsetCache

### Inherited from Logging

### Inherited from AnyRef

### Inherited from Any

### Ungrouped