Packages

package scaladsl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. class MetadataClient extends AnyRef
  2. trait PartitionAssignmentHandler extends AnyRef

    The API is new and may change in further releases.

    The API is new and may change in further releases.

    Allows the user to execute user code when Kafka rebalances partitions between consumers, or a Pekko Connectors Kafka consumer is stopped. Use with care: These callbacks are called synchronously on the same thread Kafka's poll() is called. A warning will be logged if a callback takes longer than the configured partition-handler-warning.

    There is no point in calling Committable's commit methods as their committing won't be executed as long as any of the callbacks in this class are called. Calling commitSync on the passed pekko.kafka.RestrictedConsumer is available.

    This complements the methods of Kafka's ConsumerRebalanceListener with an onStop callback which is called before Consumer.close.

  3. final class SendProducer[K, V] extends AnyRef

    Utility class for producing to Kafka without using Apache Pekko Streams.

Value Members

  1. object Committer
  2. object Consumer

    Apache Pekko Stream connector for subscribing to Kafka topics.

  3. object DiscoverySupport

    Scala API.

    Scala API.

    Reads Kafka bootstrap servers from configured sources via pekko.discovery.Discovery configuration.

  4. object MetadataClient
  5. object Producer

    Apache Pekko Stream connector for publishing messages to Kafka topics.

  6. object SendProducer
  7. object Transactional

    Apache Pekko Stream connector to support transactions between Kafka topics.

Ungrouped