< 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

# KafkaAdminClientActor 

###

#### case class KafkaAdminClientActor(config: KafkaAdminClientActorConfig) extends BaseClusterQueryActor with LongRunningPoolActor with Product with Serializable

Linear Supertypes
Serializable, Serializable, Product, Equals, LongRunningPoolActor, BaseClusterQueryActor, BaseClusterActor, BaseQueryActor, BaseActor, ActorLogging, Actor, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. KafkaAdminClientActor
2. Serializable
3. Serializable
4. Product
5. Equals
6. LongRunningPoolActor
7. BaseClusterQueryActor
8. BaseClusterActor
9. BaseQueryActor
10. BaseActor
11. ActorLogging
12. Actor
13. AnyRef
14. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new KafkaAdminClientActor(config: KafkaAdminClientActorConfig)

### Type Members

1.  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.  def clone(): AnyRef
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
11.  implicit lazy val clusterConfig: ClusterConfig
    Attributes
      protected
    Definition Classes
      BaseClusterActor
12.  implicit val clusterContext: ClusterContext
    Attributes
      protected
    Definition Classes
      KafkaAdminClientActor → BaseClusterActor
13.  implicit lazy val clusterFeatures: ClusterFeatures
    Attributes
      protected
    Definition Classes
      BaseClusterActor
14.  val config: KafkaAdminClientActorConfig
15.  implicit val context: ActorContext
    Definition Classes
      Actor
16.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
17.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
18.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
19.  def hasCapacityFor(taskCount: Int): Boolean
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
20.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
21.  def log: LoggingAdapter
    Definition Classes
      ActorLogging
22.  def longRunning[T](fn: ⇒ Future[T])(implicit ec: ExecutionContext, ct: ClassTag[T]): Unit
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
23.  val longRunningExecutionContext: ExecutionContextExecutor
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
24.  val longRunningExecutor: ThreadPoolExecutor
    Attributes
      protected
    Definition Classes
      LongRunningPoolActor
25.  def longRunningPoolConfig: LongRunningPoolConfig
    Attributes
      protected
    Definition Classes
      KafkaAdminClientActor → LongRunningPoolActor
26.  def longRunningQueueFull(): Unit
    Attributes
      protected
    Definition Classes
      KafkaAdminClientActor → LongRunningPoolActor
27.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
28.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
29.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
30.  def postRestart(reason: Throwable): Unit
    Definition Classes
      Actor
    Annotations
      @throws( classOf[java.lang.Exception] )
31.  def postStop(): Unit
    Definition Classes
      KafkaAdminClientActor → LongRunningPoolActor → BaseQueryActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
32.  def preRestart(reason: Throwable, message: Option[Any]): Unit
    Definition Classes
      KafkaAdminClientActor → BaseQueryActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
33.  def preStart(): Unit
    Definition Classes
      KafkaAdminClientActor → BaseQueryActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
34.  final def processActorRequest(request: ActorRequest): Unit
    Definition Classes
      BaseQueryActor → BaseActor
35.  def processActorResponse(response: ActorResponse): Unit
    Definition Classes
      KafkaAdminClientActor → BaseActor
36.  def processQueryRequest(request: QueryRequest): Unit
    Definition Classes
      KafkaAdminClientActor → BaseQueryActor
37.  final def receive: Receive
    Definition Classes
      BaseActor → Actor
38.  implicit final val self: ActorRef
    Definition Classes
      Actor
39.  final def sender(): ActorRef
    Definition Classes
      Actor
40.  var shutdown: Boolean
    Definition Classes
      BaseActor
41.  def supervisorStrategy: SupervisorStrategy
    Definition Classes
      Actor
42.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
43.  def unhandled(message: Any): Unit
    Definition Classes
      Actor
44.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
45.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
46.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from Serializable

### Inherited from Product

### Inherited from Equals

### Inherited from LongRunningPoolActor

### Inherited from BaseClusterQueryActor

### Inherited from BaseClusterActor

### Inherited from BaseQueryActor

### Inherited from BaseActor

### Inherited from ActorLogging

### Inherited from Actor

### Inherited from AnyRef

### Inherited from Any

### Ungrouped