class ProducerSettings[K, V] extends AnyRef

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

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

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. val closeProducerOnStop: Boolean
  7. val closeTimeout: FiniteDuration
  8. def createKafkaProducer(): Producer[K, V]

    Create a Producer instance from these settings.

    Create a Producer instance from these settings.

    This will fail with IllegalStateException if asynchronous enrichment is set up -- always prefer createKafkaProducerAsync() or createKafkaProducerCompletionStage().

    Exceptions thrown

    IllegalStateException if asynchronous enrichment is set via withEnrichAsync or withEnrichCompletionStage, you must use createKafkaProducerAsync / createKafkaProducerCompletionStage to apply it

  9. def createKafkaProducerAsync()(implicit executionContext: ExecutionContext): Future[Producer[K, V]]

    Scala API.

    Scala API.

    Create a Kafka Producer instance from these settings (without blocking for enriched).

  10. def createKafkaProducerCompletionStage(executor: Executor): CompletionStage[Producer[K, V]]

    Java API.

    Java API.

    Create a Kafka Producer instance from these settings (without blocking for enriched).

    executor

    Executor for asynchronous producer creation

  11. val dispatcher: String
  12. val enrichAsync: Option[(ProducerSettings[K, V]) => Future[ProducerSettings[K, V]]]
  13. def enriched: Future[ProducerSettings[K, V]]

    Applies enrichAsync to complement these settings from asynchronous sources.

  14. val eosCommitInterval: FiniteDuration
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  17. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. def getProperties: Map[String, AnyRef]

    Get the Kafka producer settings as map.

  19. def getProperty(key: String): String

    Java API: Get a raw property.

    Java API: Get a raw property. null if it is not defined.

  20. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  21. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  22. val keySerializerOpt: Option[Serializer[K]]
  23. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  26. val parallelism: Int
  27. val producerFactorySync: Option[(ProducerSettings[K, V]) => Producer[K, V]]
  28. val properties: Map[String, String]
  29. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  30. def toString(): String
    Definition Classes
    ProducerSettings → AnyRef → Any
  31. val transactionIdPrefix: String
  32. val valueSerializerOpt: Option[Serializer[V]]
  33. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  34. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  35. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  36. def withBootstrapServers(bootstrapServers: String): ProducerSettings[K, V]

    A comma-separated list of host/port pairs to use for establishing the initial connection to the Kafka cluster.

  37. def withClientId(clientId: String): ProducerSettings[K, V]

    An id string to pass to the server when making requests.

    An id string to pass to the server when making requests. The purpose of this is to be able to track the source of requests beyond just ip/port by allowing a logical application name to be included in server-side request logging.

  38. def withCloseProducerOnStop(closeProducerOnStop: Boolean): ProducerSettings[K, V]

    Call KafkaProducer.close on the org.apache.kafka.clients.producer.KafkaProducer when the producer stage receives a shutdown signal.

  39. def withCloseTimeout(closeTimeout: Duration): ProducerSettings[K, V]

    Java API: Duration to wait for KafkaProducer.close to finish.

  40. def withCloseTimeout(closeTimeout: FiniteDuration): ProducerSettings[K, V]

    Duration to wait for KafkaProducer.close to finish.

  41. def withDispatcher(dispatcher: String): ProducerSettings[K, V]

    Fully qualified config path which holds the dispatcher configuration to be used by the producer stages.

    Fully qualified config path which holds the dispatcher configuration to be used by the producer stages. Some blocking may occur. When this value is empty, the dispatcher configured for the stream will be used.

  42. def withEnrichAsync(value: (ProducerSettings[K, V]) => Future[ProducerSettings[K, V]]): ProducerSettings[K, V]

    Scala API.

    Scala API. A hook to allow for resolving some settings asynchronously.

    Since

    2.0.0

  43. def withEnrichCompletionStage(value: Function[ProducerSettings[K, V], CompletionStage[ProducerSettings[K, V]]]): ProducerSettings[K, V]

    Java API.

    Java API. A hook to allow for resolving some settings asynchronously.

    Since

    2.0.0

  44. def withEosCommitInterval(eosCommitInterval: Duration): ProducerSettings[K, V]

    Java API: The time interval to commit a transaction when using the Transactional.sink or Transactional.flow.

  45. def withEosCommitInterval(eosCommitInterval: FiniteDuration): ProducerSettings[K, V]

    The time interval to commit a transaction when using the Transactional.sink or Transactional.flow.

  46. def withParallelism(parallelism: Int): ProducerSettings[K, V]

    Tuning parameter of how many sends that can run in parallel.

  47. def withProducer(producer: Producer[K, V]): ProducerSettings[K, V]

    Replaces the default Kafka producer creation logic with an external producer.

    Replaces the default Kafka producer creation logic with an external producer. This will also set closeProducerOnStop = false by default.

  48. def withProducerFactory(factory: (ProducerSettings[K, V]) => Producer[K, V]): ProducerSettings[K, V]

    Replaces the default Kafka producer creation logic.

  49. def withProperties(properties: Map[String, String]): ProducerSettings[K, V]

    Java API: The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.producer.ProducerConfig.

  50. def withProperties(properties: (String, String)*): ProducerSettings[K, V]

    Scala API: The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.producer.ProducerConfig.

  51. def withProperties(properties: Map[String, String]): ProducerSettings[K, V]

    Scala API: The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.producer.ProducerConfig.

  52. def withProperty(key: String, value: String): ProducerSettings[K, V]

    The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.producer.ProducerConfig.

  53. def withTransactionIdPrefix(transactionIdPrefix: String): ProducerSettings[K, V]

    The prefix to append to the generated transaction id when using the Transactional.sink or Transactional.flow.

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  2. def producerFactory: (ProducerSettings[K, V]) => Producer[K, V]
    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use createKafkaProducer(), createKafkaProducerAsync(), or createKafkaProducerCompletionStage() to get a new KafkaProducer

Inherited from AnyRef

Inherited from Any

Ungrouped