< 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

# KafkaManagedOffsetCache 

###
Companion object KafkaManagedOffsetCache

#### case class KafkaManagedOffsetCache(clusterContext: ClusterContext, adminClient: KafkaAdminClient, consumerProperties: Option[Properties], bootstrapBrokerList: BrokerList, config: KafkaManagedOffsetCacheConfig) extends Runnable with Closeable with Logging with Product with Serializable

Linear Supertypes
Serializable, Serializable, Product, Equals, Logging, Closeable, AutoCloseable, Runnable, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. KafkaManagedOffsetCache
2. Serializable
3. Serializable
4. Product
5. Equals
6. Logging
7. Closeable
8. AutoCloseable
9. Runnable
10. AnyRef
11. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new KafkaManagedOffsetCache(clusterContext: ClusterContext, adminClient: KafkaAdminClient, consumerProperties: Option[Properties], bootstrapBrokerList: BrokerList, config: KafkaManagedOffsetCacheConfig)

### 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.  val adminClient: KafkaAdminClient
5.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
6.  val bootstrapBrokerList: BrokerList
7.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
8.  def close(): Unit
   Definition Classes
     KafkaManagedOffsetCache → Closeable → AutoCloseable
9.  val clusterContext: ClusterContext
10.  val config: KafkaManagedOffsetCacheConfig
11.  val consumerProperties: Option[Properties]
12.  val consumerTopicSetMap: TrieMap[String, Set[String]]
13.  def debug(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
14.  def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
15.  def debug(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
16.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
17.  def error(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
18.  def error(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
19.  def error(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
20.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
21.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
22.  def getConsumerTopics(group: String): Set[String]
23.  def getConsumers: IndexedSeq[String]
24.  def getLastUpdateTimeMillis: Long
25.  def getOffset(group: String, topic: String, part: Int): Option[Long]
26.  def getOwner(group: String, topic: String, part: Int): Option[String]
27.  def getTopicConsumers(topic: String): Set[String]
28.  val groupTopicPartitionMemberMap: Cache[(String, String, Int), MemberMetadata]
29.  val groupTopicPartitionMemberSet: Set[(String, String, Int)]
30.  val groupTopicPartitionOffsetMap: Cache[(String, String, Int), OffsetAndMetadata]
31.  val groupTopicPartitionOffsetSet: Set[(String, String, Int)]
32.  def info(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
33.  def info(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
34.  def info(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
35.  def isDebugEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
36.  def isErrorEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
37.  def isInfoEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
38.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
39.  def isTraceEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
40.  def isWarnEnabled: Boolean
    Attributes
      protected
    Definition Classes
      Logging
41.  def logger: Logger
    Attributes
      protected
    Definition Classes
      Logging
42.  def loggerName: String
    Attributes
      protected
    Definition Classes
      Logging
43.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
44.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
45.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
46.  def run(): Unit
    Definition Classes
      KafkaManagedOffsetCache → Runnable
47.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
48.  val topicConsumerSetMap: TrieMap[String, Set[String]]
49.  def trace(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
50.  def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
51.  def trace(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging
52.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
53.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
54.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
55.  def warn(mkr: Marker, msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
56.  def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit
    Attributes
      protected
    Definition Classes
      Logging
57.  def warn(msg: ⇒ Any): Unit
    Attributes
      protected
    Definition Classes
      Logging

### Inherited from Serializable

### Inherited from Product

### Inherited from Equals

### Inherited from Logging

### Inherited from Closeable

### Inherited from AutoCloseable

### Inherited from Runnable

### Inherited from AnyRef

### Inherited from Any

### Ungrouped