package kafka

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package cluster
  2. package internal
  3. package javadsl
  4. package scaladsl
  5. package testkit

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

    Commits will be failed with this exception if Kafka doesn't respond within commit-timeout

  4. sealed trait CommitWhen extends AnyRef
    Annotations
    @ApiMayChange()
  5. class CommitterSettings extends AnyRef

    Settings for committer.

    Settings for committer. See pekko.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.

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

    Kafka consumer stages fail with this exception.

  8. sealed trait ConsumerRebalanceEvent extends AnyRef
    Annotations
    @ApiMayChange()
  9. class ConsumerSettings[K, V] extends AnyRef

    Settings for consumers.

    Settings for consumers. See pekko.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.

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

    Kafka-speak for these is "Assignments".

  13. class OffsetResetProtectionSettings extends AnyRef
  14. class ProducerSettings[K, V] extends AnyRef

    Settings for producers.

    Settings for producers. See pekko.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.

  15. final class RestrictedConsumer extends AnyRef

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

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

    Annotations
    @ApiMayChange()
  16. sealed trait Subscription extends AnyRef
  17. final case class TopicPartitionsAssigned(sub: Subscription, topicPartitions: Set[TopicPartition]) extends ConsumerRebalanceEvent with Product with Serializable
    Annotations
    @ApiMayChange()
  18. final case class TopicPartitionsRevoked(sub: Subscription, topicPartitions: Set[TopicPartition]) extends ConsumerRebalanceEvent with Product with Serializable
    Annotations
    @ApiMayChange()
  19. 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 CommitWhen

    Selects when the stream will commit an offset.

    Selects when the stream will commit an offset.

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

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

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

  9. object OffsetResetProtectionSettings

    The thresholds after which reset protection is enabled.

    The thresholds after which reset protection is enabled. Offsets, time, or both can be provided.

  10. object ProducerMessage

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

  11. object ProducerSettings
  12. object Subscriptions
  13. object Version

Ungrouped