p

akka

kafka

package kafka

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. sealed trait AutoSubscription extends Subscription
  2. class CommitTimeoutException extends TimeoutException

    Calls to commitJavadsl and commitScaladsl will be failed with this exception if Kafka doesn't respond within commit-timeout

  3. class CommitterSettings extends AnyRef

    Settings for committer.

    Settings for committer. See akka.kafka.committer section in reference.conf. Note that the companion object provides apply and create functions for convenient construction of the settings, together with the with methods.

  4. class ConsumerFailed extends RuntimeException

    Kafka consumer stages fail with this exception.

  5. sealed trait ConsumerRebalanceEvent extends AnyRef
  6. class ConsumerSettings[K, V] extends AnyRef

    Settings for consumers.

    Settings for consumers. See akka.kafka.consumer section in reference.conf. Note that the companion object provides apply and create functions for convenient construction of the settings, together with the with methods.

    The constructor is Internal API.

  7. class InitialPollFailed extends ConsumerFailed
  8. sealed trait ManualSubscription extends Subscription
  9. class ProducerSettings[K, V] extends AnyRef

    Settings for producers.

    Settings for producers. See akka.kafka.producer section in reference.conf. Note that the companion object provides apply and create functions for convenient construction of the settings, together with the with methods.

    The constructor is Internal API.

  10. sealed trait Subscription extends AnyRef
  11. final case class TopicPartitionsAssigned(sub: Subscription, topicPartitions: Set[TopicPartition]) extends ConsumerRebalanceEvent with Product with Serializable
  12. final case class TopicPartitionsRevoked(sub: Subscription, topicPartitions: Set[TopicPartition]) extends ConsumerRebalanceEvent with Product with Serializable
  13. class WakeupsExceeded extends ConsumerFailed

Value Members

  1. object CommitterSettings
  2. object ConsumerMessage

    Classes that are used in both javadsl.Consumer and scaladsl.Consumer.

  3. object ConsumerSettings
  4. object KafkaConsumerActor
  5. object Metadata

    Messages for Kafka metadata fetching via KafkaConsumerActor.

    Messages for Kafka metadata fetching via KafkaConsumerActor.

    NOTE: Processing of these requests blocks the actor loop. The KafkaConsumerActor is configured to run on its own dispatcher, so just as the other remote calls to Kafka, the blocking happens within a designated thread pool. However, calling these during consuming might affect performance and even cause timeouts in extreme cases.

  6. object ProducerMessage

    Classes that are used in both javadsl.Producer and scaladsl.Producer.

  7. object ProducerSettings
  8. object Subscriptions

Ungrouped