o

akka.kafka

KafkaConsumerActor

object KafkaConsumerActor

Source
KafkaConsumerActor.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KafkaConsumerActor
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. case class StoppingException() extends RuntimeException with Product with Serializable

Value Members

  1. def props[K, V](owner: ActorRef, settings: ConsumerSettings[K, V]): Props

    Creates Props for the Kafka Consumer Actor with a reference back to the owner of it which will be signalled with Failure(exception), in case the Kafka client instance can't be created.

  2. def props[K, V](settings: ConsumerSettings[K, V]): Props

    Creates Props for the Kafka Consumer Actor.

  3. val stop: Stop.type

    Java API: Message to send for stopping the Kafka consumer actor.

  4. case object Stop extends NoSerializationVerificationNeeded with StopLike with Product with Serializable

    Message to send for stopping the Kafka consumer actor.