p

akka

kafka

package kafka

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. sealed trait AutoSubscription extends Subscription

    Kafka-speak for these is "Subscriptions".

  2. sealed trait CommitDelivery extends AnyRef
    Annotations
    @ApiMayChange()
  3. class CommitTimeoutException extends TimeoutException

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

  4. 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.

  5. class ConnectionCheckerSettings extends AnyRef
  6. class ConsumerFailed extends RuntimeException

    Kafka consumer stages fail with this exception.

  7. sealed trait ConsumerRebalanceEvent extends AnyRef
  8. 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.

  9. class InitialPollFailed extends ConsumerFailed
  10. final case class KafkaConnectionFailed(te: TimeoutException, attempts: Int) extends Exception with Product with Serializable
  11. sealed trait ManualSubscription extends Subscription

    Kafka-speak for these is "Assignments".

  12. 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.

  13. final class RestrictedConsumer extends AnyRef

    Offers parts of the org.apache.kafka.clients.consumer.Consumer API which becomes available to the akka.kafka.scaladsl.PartitionAssignmentHandler callbacks.

    Offers parts of the org.apache.kafka.clients.consumer.Consumer API which becomes available to the akka.kafka.scaladsl.PartitionAssignmentHandler callbacks.

    Annotations
    @ApiMayChange()
  14. sealed trait Subscription extends AnyRef
  15. final case class TopicPartitionsAssigned(sub: Subscription, topicPartitions: Set[TopicPartition]) extends ConsumerRebalanceEvent with Product with Serializable
  16. final case class TopicPartitionsRevoked(sub: Subscription, topicPartitions: Set[TopicPartition]) extends ConsumerRebalanceEvent with Product with Serializable
  17. class WakeupsExceeded extends ConsumerFailed

Value Members

  1. object CommitDelivery

    Selects how the stream delivers commits to the internal actor.

    Selects how the stream delivers commits to the internal actor.

    Annotations
    @ApiMayChange()
  2. object CommitterSettings
  3. object ConnectionCheckerSettings
  4. object ConsumerMessage

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

  5. object ConsumerSettings
  6. object KafkaConsumerActor
  7. 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.

  8. object ProducerMessage

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

  9. object ProducerSettings
  10. object Subscriptions

Ungrouped