Packages

o

akka.kafka.scaladsl

DiscoverySupport

object DiscoverySupport

Scala API.

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

Source
DiscoverySupport.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DiscoverySupport
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def consumerBootstrapServers[K, V](config: Config)(system: ActorSystem): (ConsumerSettings[K, V]) => Future[ConsumerSettings[K, V]]
  2. def consumerBootstrapServers[K, V](config: Config)(implicit system: ClassicActorSystemProvider): (ConsumerSettings[K, V]) => Future[ConsumerSettings[K, V]]

    Expects a service section in the given Config and reads the given service name's address to be used as bootstrapServers.

  3. def producerBootstrapServers[K, V](config: Config)(system: ActorSystem): (ProducerSettings[K, V]) => Future[ProducerSettings[K, V]]
  4. def producerBootstrapServers[K, V](config: Config)(implicit system: ClassicActorSystemProvider): (ProducerSettings[K, V]) => Future[ProducerSettings[K, V]]

    Expects a service section in the given Config and reads the given service name's address to be used as bootstrapServers.