< 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

# KafkaStateActor 

###

#### class KafkaStateActor extends BaseClusterQueryCommandActor with LongRunningPoolActor

Linear Supertypes
LongRunningPoolActor, BaseClusterQueryCommandActor, BaseClusterActor, BaseQueryCommandActor, BaseActor, ActorLogging, Actor, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. KafkaStateActor
2. LongRunningPoolActor
3. BaseClusterQueryCommandActor
4. BaseClusterActor
5. BaseQueryCommandActor
6. BaseActor
7. ActorLogging
8. Actor
9. AnyRef
10. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new KafkaStateActor(config: KafkaStateActorConfig)

### Type Members

1.  class KafkaTopicOffsetGetter extends Runnable
2.  type Receive = PartialFunction[Any, Unit]
   Definition Classes
     Actor

### 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.  def aroundPostRestart(reason: Throwable): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
5.  def aroundPostStop(): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
6.  def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
7.  def aroundPreStart(): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
8.  def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
9.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
10.  implicit val cf: ClusterFeatures
    Attributes
      protected
11.  def clone(): AnyRef
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
12.  implicit lazy val clusterConfig: ClusterConfig
    Attributes
      protected
    Definition Classes
      BaseClusterActor
13.  implicit val clusterContext: ClusterContext
    Attributes
      protected
    Definition Classes
      KafkaStateActor → BaseClusterActor
14.  implicit lazy val clusterFeatures: ClusterFeatures
    Attributes
      protected
    Definition Classes
      BaseClusterActor
15.  implicit val context: ActorContext
    Definition Classes
      Actor
16.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
17.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
18.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
19.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
20.  def getPartitionLeaders(topic: String): Option[List[(Int, Option[BrokerIdentity])]]
21.  def getTopicDescription(topic: String, interactive: Boolean): Option[TopicDescription]
22.  def getTopicPartitionOffsetsNotFuture(topic: String, interactive: Boolean): PartitionOffsetsCapture
23.  def getTopicZookeeperData(topic: String): Option[(Int, String)]
24.  def hasCapacityFor(taskCount: Int): Boolean
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
25.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
26.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
27.  def log: LoggingAdapter
    Definition Classes
      ActorLogging
28.  def longRunning[T](fn: ⇒ Future[T])(implicit ec: ExecutionContext, ct: ClassTag[T]): Unit
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
29.  val longRunningExecutionContext: ExecutionContextExecutor
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
30.  val longRunningExecutor: ThreadPoolExecutor
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
31.  def longRunningPoolConfig: LongRunningPoolConfig
    Attributes
      protected
    Definition Classes
      KafkaStateActor → LongRunningPoolActor
32.  def longRunningQueueFull(): Unit
    Attributes
      protected
    Definition Classes
      KafkaStateActor → LongRunningPoolActor
33.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
34.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
35.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
36.  def postRestart(reason: Throwable): Unit
    Definition Classes
      Actor
    Annotations
      @throws( classOf[java.lang.Exception] )
37.  def postStop(): Unit
    Definition Classes
      KafkaStateActor → LongRunningPoolActor → BaseQueryCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
38.  def preRestart(reason: Throwable, message: Option[Any]): Unit
    Definition Classes
      KafkaStateActor → BaseQueryCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
39.  def preStart(): Unit
    Definition Classes
      KafkaStateActor → BaseQueryCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
40.  final def processActorRequest(request: ActorRequest): Unit
    Definition Classes
      BaseQueryCommandActor → BaseActor
41.  def processActorResponse(response: ActorResponse): Unit
    Definition Classes
      KafkaStateActor → BaseActor
42.  def processCommandRequest(request: CommandRequest): Unit
    Definition Classes
      KafkaStateActor → BaseQueryCommandActor
43.  def processQueryRequest(request: QueryRequest): Unit
    Definition Classes
      KafkaStateActor → BaseQueryCommandActor
44.  final def receive: Receive
    Definition Classes
      BaseActor → Actor
45.  implicit final val self: ActorRef
    Definition Classes
      Actor
46.  final def sender(): ActorRef
    Definition Classes
      Actor
47.  var shutdown: Boolean
    Definition Classes
      BaseActor
48.  def startTopicOffsetGetter(): Unit
49.  def stopTopicOffsetGetter(): Unit
50.  def supervisorStrategy: SupervisorStrategy
    Definition Classes
      Actor
51.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
52.  def toString(): String
    Definition Classes
      AnyRef → Any
53.  def unhandled(message: Any): Unit
    Definition Classes
      Actor
54.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
55.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
56.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from LongRunningPoolActor

### Inherited from BaseClusterQueryCommandActor

### Inherited from BaseClusterActor

### Inherited from BaseQueryCommandActor

### Inherited from BaseActor

### Inherited from ActorLogging

### Inherited from Actor

### Inherited from AnyRef

### Inherited from Any

### Ungrouped