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
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ProducerSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ProducerSettings(properties: Map[String, String], keySerializerOpt: Option[Serializer[K]], valueSerializerOpt: Option[Serializer[V]], closeTimeout: FiniteDuration, parallelism: Int, dispatcher: String, eosCommitInterval: FiniteDuration)
    Annotations
    @deprecated
    Deprecated

    (Since version 1.0-M1) use the factory methods ProducerSettings.apply and create instead

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[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. val closeTimeout: FiniteDuration
  7. def createKafkaProducer(): Producer[K, V]

    Create a Producer instance from the settings.

  8. val dispatcher: String
  9. val eosCommitInterval: FiniteDuration
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  12. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def getProperties: Map[String, AnyRef]

    Get the Kafka producer settings as map.

  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. val keySerializerOpt: Option[Serializer[K]]
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. val parallelism: Int
  22. val producerFactory: (ProducerSettings[K, V]) ⇒ Producer[K, V]
  23. val properties: Map[String, String]
  24. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    ProducerSettings → AnyRef → Any
  26. val valueSerializerOpt: Option[Serializer[V]]
  27. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  30. 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.

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

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

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

    Duration to wait for KafkaConsumer.close to finish.

  33. 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.

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

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

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

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

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

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

  37. def withProducerFactory(factory: (ProducerSettings[K, V]) ⇒ Producer[K, V]): ProducerSettings[K, V]

    Replaces the default Kafka producer creation logic.

  38. 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.

  39. 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.

  40. 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.

  41. 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.

Inherited from AnyRef

Inherited from Any

Ungrouped