kafka.producer

ProducerConfig

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
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ProducerConfig(originalProps: Properties)

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

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

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. val batchNumMessages: Int

    the number of messages batched at the producer

    the number of messages batched at the producer

    Definition Classes
    AsyncProducerConfig
  8. val brokerList: String

    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.

  9. val clientId: String

    Definition Classes
    SyncProducerConfigShared
  10. def clone(): AnyRef

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

    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

  12. val compressionCodec: CompressionCodec

    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

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

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

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

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

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

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

    Definition Classes
    Any
  19. val keySerializerClass: String

    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
  20. val messageSendMaxRetries: Int

    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.

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

    Definition Classes
    AnyRef
  22. final def notify(): Unit

    Definition Classes
    AnyRef
  23. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  24. val partitionerClass: String

    the partitioner class for partitioning events amongst sub-topics

  25. val producerType: String

    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

  26. val props: VerifiableProperties

  27. val queueBufferingMaxMessages: Int

    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
  28. val queueBufferingMaxMs: Int

    Definition Classes
    AsyncProducerConfig
  29. val queueEnqueueTimeoutMs: Int

    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
  30. val requestRequiredAcks: Short

    Definition Classes
    SyncProducerConfigShared
  31. val requestTimeoutMs: Int

    Definition Classes
    SyncProducerConfigShared
  32. val retryBackoffMs: Int

    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.

  33. val sendBufferBytes: Int

    Definition Classes
    SyncProducerConfigShared
  34. val serializerClass: String

    the serializer class for values

    the serializer class for values

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

    Definition Classes
    AnyRef
  36. def toString(): String

    Definition Classes
    AnyRef → Any
  37. val topicMetadataRefreshIntervalMs: Int

    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

  38. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from SyncProducerConfigShared

Inherited from AsyncProducerConfig

Inherited from AnyRef

Inherited from Any

Ungrouped