< 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

t

kafka.manager.actor.cluster

# OffsetCache 

###

#### trait OffsetCache extends Logging

Linear Supertypes
Logging, AnyRef, Any
Known Subclasses
OffsetCacheActive, OffsetCachePassive
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. OffsetCache
2. Logging
3. AnyRef
4. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Abstract Value Members

1.  implicit abstract def cf: ClusterFeatures
   Attributes
     protected[this]
2.  abstract def clusterContext: ClusterContext
3.  abstract def consumerProperties: Option[Properties]
4.  implicit abstract def ec: ExecutionContext
   Attributes
     protected[this]
5.  abstract def getBrokerList: () ⇒ BrokerList
   Attributes
     protected
6.  abstract def getCacheTimeoutSecs: Int
7.  abstract def getConsumerTopicsFromIds(consumer: String): Set[String]
   Attributes
     protected
8.  abstract def getConsumerTopicsFromOffsets(consumer: String): Set[String]
   Attributes
     protected
9.  abstract def getConsumerTopicsFromOwners(consumer: String): Set[String]
   Attributes
     protected
10.  abstract def getKafkaVersion: KafkaVersion
11.  abstract def getSimpleConsumerSocketTimeoutMillis: Int
12.  abstract def getTopicDescription(topic: String, interactive: Boolean): Option[TopicDescription]
    Attributes
      protected
13.  abstract def getTopicPartitionLeaders(topic: String): Option[List[(Int, Option[BrokerIdentity])]]
    Attributes
      protected
14.  abstract def getZKManagedConsumerList: IndexedSeq[ConsumerNameAndType]
    Attributes
      protected
15.  abstract def kafkaAdminClient: KafkaAdminClient
16.  abstract def kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig
17.  abstract def lastUpdateMillisZK: Long
    Attributes
      protected
18.  abstract val loadOffsets: Boolean
    Attributes
      protected[this]
19.  abstract def readConsumerOffsetByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, Long]
    Attributes
      protected
20.  abstract def readConsumerOwnerByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, String]
    Attributes
      protected

### Concrete 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.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
6.  def debug(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
   Attributes
     protected
   Definition Classes
     Logging
7.  def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit
   Attributes
     protected
   Definition Classes
     Logging
8.  def debug(msg: ⇒ Any): Unit
   Attributes
     protected
   Definition Classes
     Logging
9.  final def eq(arg0: AnyRef): Boolean
   Definition Classes
     AnyRef
10.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
11.  def error(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
12.  def error(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
13.  def error(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
14.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
15.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
16.  final def getConsumedTopicDescription(consumer: String, topic: String, interactive: Boolean, consumerType: ConsumerType): ConsumedTopicDescription
17.  final def getConsumerDescription(consumer: String, consumerType: ConsumerType): ConsumerDescription
18.  final def getConsumerList: ConsumerList
19.  def getConsumerTopics(consumer: String): Set[String]
    Attributes
      protected
20.  def getKafkaManagedConsumerList: IndexedSeq[ConsumerNameAndType]
    Attributes
      protected
21.  def getKafkaManagedConsumerTopics(consumer: String): Set[String]
    Attributes
      protected
22.  def getTopicPartitionOffsets(topic: String, interactive: Boolean): Future[PartitionOffsetsCapture]
23.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
24.  def info(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
25.  def info(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
26.  def info(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
27.  def isDebugEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
28.  def isErrorEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
29.  def isInfoEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
30.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
31.  def isTraceEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
32.  def isWarnEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
33.  final def lastUpdateMillis: Long
34.  def logger: Logger
    Attributes
      protected
    Definition Classes
      Logging
35.  def loggerName: String
    Attributes
      protected
    Definition Classes
      Logging
36.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
37.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
38.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
39.  def readKafkaManagedConsumerOffsetByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, Long]
    Attributes
      protected
40.  def readKafkaManagedConsumerOwnerByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, String]
    Attributes
      protected
41.  def start(): Unit
42.  def stop(): Unit
43.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
44.  def toString(): String
    Definition Classes
      AnyRef → Any
45.  def trace(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
46.  def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
47.  def trace(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
48.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
49.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
50.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
51.  def warn(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
52.  def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
53.  def warn(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging

### Inherited from Logging

### Inherited from AnyRef

### Inherited from Any

### Ungrouped