Struct RdKafkaPropertiesProducer

pub struct RdKafkaPropertiesProducer {

    pub allow_auto_create_topics: Option<bool>,
    pub queue_buffering_max_messages: Option<usize>,
    queue_buffering_max_kbytes: Option<usize>,
    queue_buffering_max_ms: Option<f64>,
    enable_idempotence: Option<bool>,
    message_send_max_retries: Option<usize>,
    retry_backoff_ms: Option<usize>,
    batch_num_messages: Option<usize>,
    batch_size: Option<usize>,
    compression_codec: Option<CompressionCodec>,
    message_timeout_ms: Option<usize>,
    max_in_flight_requests_per_connection: usize,
    request_required_acks: Option<i32>,
}

See https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md for the detailed meaning of these librdkafka producer properties

Fields

allow_auto_create_topics: Option<bool>

Allow automatic topic creation on the broker when subscribing to or assigning non-existent topics.

queue_buffering_max_messages: Option<usize>

Maximum number of messages allowed on the producer queue. This queue is shared by all topics and partitions. A value of 0 disables this limit.

queue_buffering_max_kbytes: Option<usize>

Maximum total message size sum allowed on the producer queue. This queue is shared by all topics and partitions. This property has higher priority than queue.buffering.max.messages.

queue_buffering_max_ms: Option<f64>

Delay in milliseconds to wait for messages in the producer queue to accumulate before constructing message batches (MessageSets) to transmit to brokers. A higher value allows larger and more effective (less overhead, improved compression) batches of messages to accumulate at the expense of increased message delivery latency.

enable_idempotence: Option<bool>

When set to true, the producer will ensure that messages are successfully produced exactly once and in the original produce order. The following configuration properties are adjusted automatically (if not modified by the user) when idempotence is enabled: max.in.flight.requests.per.connection=5 (must be less than or equal to 5), retries=INT32_MAX (must be greater than 0), acks=all, queuing.strategy=fifo. Producer will fail if user-supplied configuration is incompatible.

message_send_max_retries: Option<usize>

How many times to retry sending a failing Message.

retry_backoff_ms: Option<usize>

The backoff time in milliseconds before retrying a protocol request.

batch_num_messages: Option<usize>

Maximum number of messages batched in one MessageSet

batch_size: Option<usize>

Maximum size (in bytes) of all messages batched in one MessageSet, including protocol framing overhead. This limit is applied after the first message has been added to the batch, regardless of the first message’s size, this is to ensure that messages that exceed batch.size are produced.

compression_codec: Option<CompressionCodec>

Compression codec to use for compressing message sets.

message_timeout_ms: Option<usize>

Produce message timeout. This value is used to limits the time a produced message waits for successful delivery (including retries).

max_in_flight_requests_per_connection: usize

The maximum number of unacknowledged requests the client will send on a single connection before blocking.

request_required_acks: Option<i32>

Implementations

impl RdKafkaPropertiesProducer

pub(crate) fn set_client(&self, c: &mut ClientConfig)

Trait Implementations

impl Clone for RdKafkaPropertiesProducer

fn clone(&self) -> RdKafkaPropertiesProducer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RdKafkaPropertiesProducer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RdKafkaPropertiesProducer

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl WithOptions for RdKafkaPropertiesProducer