package scaladsl
- Alphabetic
- Public
- Protected
Type Members
- class MetadataClient extends AnyRef
- 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 an Alpakka 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 configuredpartition-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. CallingcommitSync
on the passed akka.kafka.RestrictedConsumer is available.This complements the methods of Kafka's ConsumerRebalanceListener with an
onStop
callback which is called beforeConsumer.close
. - final class SendProducer[K, V] extends AnyRef
Utility class for producing to Kafka without using Akka Streams.
Value Members
- object Committer
- object Consumer
Akka Stream connector for subscribing to Kafka topics.
- object DiscoverySupport
Scala API.
Scala API.
Reads Kafka bootstrap servers from configured sources via akka.discovery.Discovery configuration.
- object MetadataClient
- object Producer
Akka Stream connector for publishing messages to Kafka topics.
- object SendProducer
- object Transactional
Akka Stream connector to support transactions between Kafka topics.