Class/Object

kafka.producer

ProducerConfig

Related Docs: object ProducerConfig | package producer

Permalink

class ProducerConfig extends AsyncProducerConfig with SyncProducerConfigShared

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ProducerConfig
  2. SyncProducerConfigShared
  3. AsyncProducerConfig
  4. AnyRef
  5. Any
  1. Hide All
  2. Show all
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ProducerConfig(originalProps: Properties)

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. val batchNumMessages: Int

    Permalink

    the number of messages batched at the producer

    the number of messages batched at the producer

    Definition Classes
    AsyncProducerConfig
  6. val brokerList: String

    Permalink

    This is for bootstrapping and the producer will only use it for getting metadata (topics, partitions and replicas).

    This is for bootstrapping and the producer will only use it for getting metadata (topics, partitions and replicas). The socket connections for sending the actual data will be established based on the broker information returned in the metadata. The format is host1:port1,host2:port2, and the list can be a subset of brokers or a VIP pointing to a subset of brokers.

  7. val clientId: String

    Permalink
    Definition Classes
    SyncProducerConfigShared
  8. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. val compressedTopics: Seq[String]

    Permalink

    This parameter allows you to set whether compression should be turned * on for particular topics

    This parameter allows you to set whether compression should be turned * on for particular topics

    If the compression codec is anything other than NoCompressionCodec,

    Enable compression only for specified topics if any

    If the list of compressed topics is empty, then enable the specified compression codec for all topics

    If the compression codec is NoCompressionCodec, compression is disabled for all topics

  10. val compressionCodec: CompressionCodec

    Permalink

    This parameter allows you to specify the compression codec for all data generated * by this producer.

    This parameter allows you to specify the compression codec for all data generated * by this producer. The default is NoCompressionCodec

  11. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  15. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  16. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  17. val keySerializerClass: String

    Permalink

    the serializer class for keys (defaults to the same as for values)

    the serializer class for keys (defaults to the same as for values)

    Definition Classes
    AsyncProducerConfig
  18. val messageSendMaxRetries: Int

    Permalink

    The leader may be unavailable transiently, which can fail the sending of a message.

    The leader may be unavailable transiently, which can fail the sending of a message. This property specifies the number of retries when such failures occur.

  19. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  20. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  21. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  22. val partitionerClass: String

    Permalink

    the partitioner class for partitioning events amongst sub-topics

  23. val producerType: String

    Permalink

    this parameter specifies whether the messages are sent asynchronously * or not.

    this parameter specifies whether the messages are sent asynchronously * or not. Valid values are - async for asynchronous send * sync for synchronous send

  24. val props: VerifiableProperties

    Permalink
  25. val queueBufferingMaxMessages: Int

    Permalink

    the maximum size of the blocking queue for buffering on the producer

    the maximum size of the blocking queue for buffering on the producer

    Definition Classes
    AsyncProducerConfig
  26. val queueBufferingMaxMs: Int

    Permalink
    Definition Classes
    AsyncProducerConfig
  27. val queueEnqueueTimeoutMs: Int

    Permalink

    Timeout for event enqueue: 0: events will be enqueued immediately or dropped if the queue is full -ve: enqueue will block indefinitely if the queue is full +ve: enqueue will block up to this many milliseconds if the queue is full

    Timeout for event enqueue: 0: events will be enqueued immediately or dropped if the queue is full -ve: enqueue will block indefinitely if the queue is full +ve: enqueue will block up to this many milliseconds if the queue is full

    Definition Classes
    AsyncProducerConfig
  28. val requestRequiredAcks: Short

    Permalink
    Definition Classes
    SyncProducerConfigShared
  29. val requestTimeoutMs: Int

    Permalink
    Definition Classes
    SyncProducerConfigShared
  30. val retryBackoffMs: Int

    Permalink

    Before each retry, the producer refreshes the metadata of relevant topics.

    Before each retry, the producer refreshes the metadata of relevant topics. Since leader election takes a bit of time, this property specifies the amount of time that the producer waits before refreshing the metadata.

  31. val sendBufferBytes: Int

    Permalink
    Definition Classes
    SyncProducerConfigShared
  32. val serializerClass: String

    Permalink

    the serializer class for values

    the serializer class for values

    Definition Classes
    AsyncProducerConfig
  33. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  34. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  35. val topicMetadataRefreshIntervalMs: Int

    Permalink

    The producer generally refreshes the topic metadata from brokers when there is a failure (partition missing, leader not available...).

    The producer generally refreshes the topic metadata from brokers when there is a failure (partition missing, leader not available...). It will also poll regularly (default: every 10min so 600000ms). If you set this to a negative value, metadata will only get refreshed on failure. If you set this to zero, the metadata will get refreshed after each message sent (not recommended) Important note: the refresh happen only AFTER the message is sent, so if the producer never sends a message the metadata is never refreshed

  36. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from SyncProducerConfigShared

Inherited from AsyncProducerConfig

Inherited from AnyRef

Inherited from Any

Ungrouped