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