ProducerConfig

Namespace: Kafunk

Producer configuration.

Record Field	Description
`batchLingerMs` Signature: int	The maximum time, in milliseconds, to wait for a produce request btch to reach capacity. If set to 0, no batching will be performed.
`batchSizeBytes` Signature: int	The maximum size, in bytes, of a batch of produce requests per broker. If set to 0, no batching will be performed.
`bufferSizeBytes` Signature: int	The per-broker, in-memory buffer size in bytes. When the buffer reaches capacity, backpressure is exerted on incoming produce requests.
`compression` Signature: CompressionCodec	The compression method to use. Default: None
`maxInFlightRequests` Signature: int	The maximum number of in-flight produce requests per broker connection. If this value is greater than 1, message ordering cannot be guaranteed.
`partitioner` Signature: Partitioner	A partition function which given a topic name, cluster topic metadata and the message payload, returns the partition which the message should be written to.
`requiredAcks` Signature: RequiredAcks	The acks required.
`timeout` Signature: Timeout	requirement before sending back an error to the client.
`topic` Signature: TopicName	The topic to produce to.

Static member	Description
`create(...)` Signature: (topic:TopicName * partition:Partitioner * requiredAcks:RequiredAcks option * compression:CompressionCodec option * timeout:Timeout option * bufferSizeBytes:int option * batchSizeBytes:int option * batchLingerMs:int option * maxInFlightRequests:int option) -> ProducerConfig	Creates a producer configuration.
`DefaultBatchLingerMs` Signature: int	The default per-broker, produce request linger time in ms = 1000. CompiledName: `get_DefaultBatchLingerMs`
`DefaultBatchSizeBytes` Signature: int	The default per-broker, produce request batch size in bytes = 16384. CompiledName: `get_DefaultBatchSizeBytes`
`DefaultBufferSizeBytes` Signature: int	The default in-memory, per-broker buffer size = 33554432. CompiledName: `get_DefaultBufferSizeBytes`
`DefaultMaxInFlightRequests` Signature: int	The default maximum number of in-flight requests per broker connection. CompiledName: `get_DefaultMaxInFlightRequests`
`DefaultRequiredAcks` Signature: RequiredAcks	The default required acks = RequiredAcks.AllInSync. CompiledName: `get_DefaultRequiredAcks`
`DefaultTimeoutMs` Signature: int	The default produce request timeout = 30000. CompiledName: `get_DefaultTimeoutMs`