Struct ProducerConfig 

pub struct ProducerConfig { /* private fields */ }

Configuration for the Kafka Producer.

Documentation for these configurations can be found in the Kafka documentation.

Corresponds to org.apache.kafka.clients.producer.ProducerConfig.

Implementations

impl ProducerConfig

pub const MAX_IN_FLIGHT_REQUESTS_FOR_IDEMPOTENCE: i32 = MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION_FOR_IDEMPOTENCE

Maximum number of in-flight requests per connection when idempotence is enabled.

pub const BOOTSTRAP_SERVERS_CONFIG: &'static str = "bootstrap.servers"

Config key: bootstrap.servers

pub const CLIENT_DNS_LOOKUP_CONFIG: &'static str = CommonClientConfigs::CLIENT_DNS_LOOKUP_CONFIG

Config key: client.dns.lookup. Java’s ProducerConfig.java declares it as its own public alias of CommonClientConfigs.CLIENT_DNS_LOOKUP_CONFIG.

pub const CLIENT_ID_CONFIG: &'static str = "client.id"

Config key: client.id

pub const BATCH_SIZE_CONFIG: &'static str = "batch.size"

Config key: batch.size

pub const LINGER_MS_CONFIG: &'static str = "linger.ms"

Config key: linger.ms

pub const BUFFER_MEMORY_CONFIG: &'static str = "buffer.memory"

Config key: buffer.memory

pub const MAX_BLOCK_MS_CONFIG: &'static str = "max.block.ms"

Config key: max.block.ms

pub const ACKS_CONFIG: &'static str = "acks"

Config key: acks

pub const RETRIES_CONFIG: &'static str = "retries"

Config key: retries

pub const DELIVERY_TIMEOUT_MS_CONFIG: &'static str = "delivery.timeout.ms"

Config key: delivery.timeout.ms

pub const REQUEST_TIMEOUT_MS_CONFIG: &'static str = "request.timeout.ms"

Config key: request.timeout.ms

pub const ENABLE_IDEMPOTENCE_CONFIG: &'static str = "enable.idempotence"

Config key: enable.idempotence

pub const MAX_REQUEST_SIZE_CONFIG: &'static str = "max.request.size"

Config key: max.request.size

pub const MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION: &'static str = "max.in.flight.requests.per.connection"

Config key: max.in.flight.requests.per.connection

pub const COMPRESSION_TYPE_CONFIG: &'static str = "compression.type"

Config key: compression.type

pub const CONNECTIONS_MAX_IDLE_MS_CONFIG: &'static str = "connections.max.idle.ms"

Config key: connections.max.idle.ms

pub const RECONNECT_BACKOFF_MS_CONFIG: &'static str = "reconnect.backoff.ms"

Config key: reconnect.backoff.ms

pub const RECONNECT_BACKOFF_MAX_MS_CONFIG: &'static str = "reconnect.backoff.max.ms"

Config key: reconnect.backoff.max.ms

pub const RETRY_BACKOFF_MS_CONFIG: &'static str = "retry.backoff.ms"

Config key: retry.backoff.ms

pub const RETRY_BACKOFF_MAX_MS_CONFIG: &'static str = "retry.backoff.max.ms"

Config key: retry.backoff.max.ms

pub const SEND_BUFFER_CONFIG: &'static str = "send.buffer.bytes"

Config key: send.buffer.bytes

pub const RECEIVE_BUFFER_CONFIG: &'static str = "receive.buffer.bytes"

Config key: receive.buffer.bytes

pub const METADATA_MAX_AGE_CONFIG: &'static str = "metadata.max.age.ms"

Config key: metadata.max.age.ms

pub const METADATA_MAX_IDLE_CONFIG: &'static str = "metadata.max.idle.ms"

Config key: metadata.max.idle.ms

pub const PARTITIONER_ADAPTIVE_PARTITIONING_ENABLE_CONFIG: &'static str = "partitioner.adaptive.partitioning.enable"

Config key: partitioner.adaptive.partitioning.enable

pub const PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG: &'static str = "partitioner.availability.timeout.ms"

Config key: partitioner.availability.timeout.ms

pub const PARTITIONER_IGNORE_KEYS_CONFIG: &'static str = "partitioner.ignore.keys"

Config key: partitioner.ignore.keys

pub const PARTITIONER_TYPE_CONFIG: &'static str = "partitioner.type"

Config key: partitioner.type

pub const CONSISTENT_RANDOM_PARTITIONER: &'static str = "ConsistentRandomPartitioner"

Accepted partitioner.type value selecting the CRC-32 key hash (the crate-internal KeyHasher::Crc32) — the default, librdkafka consistent_random parity.

pub const MURMUR2_RANDOM_PARTITIONER: &'static str = "Murmur2RandomPartitioner"

Accepted partitioner.type value selecting the murmur2 key hash (the crate-internal KeyHasher::Murmur2) — exact Java-client parity.

pub const ROUND_ROBIN_PARTITIONER: &'static str = "RoundRobinPartitioner"

Accepted partitioner.type value selecting the RoundRobinPartitioner.

pub const TRANSACTIONAL_ID_CONFIG: &'static str = "transactional.id"

Config key: transactional.id

pub const TRANSACTION_TIMEOUT_CONFIG: &'static str = "transaction.timeout.ms"

Config key: transaction.timeout.ms

pub const METRICS_SAMPLE_WINDOW_MS_CONFIG: &'static str = "metrics.sample.window.ms"

Config key: metrics.sample.window.ms

pub const METRICS_NUM_SAMPLES_CONFIG: &'static str = "metrics.num.samples"

Config key: metrics.num.samples

pub const METRICS_RECORDING_LEVEL_CONFIG: &'static str = "metrics.recording.level"

Config key: metrics.recording.level

pub const TRANSACTION_TWO_PHASE_COMMIT_ENABLE_CONFIG: &'static str = "transaction.two.phase.commit.enable"

Config key: transaction.two.phase.commit.enable

pub const SECURITY_PROTOCOL_CONFIG: &'static str = CommonClientConfigs::SECURITY_PROTOCOL_CONFIG

Config key: security.protocol

pub const SASL_MECHANISM_CONFIG: &'static str = SaslConfigs::SASL_MECHANISM

Config key: sasl.mechanism

pub const SASL_JAAS_CONFIG: &'static str = SaslConfigs::SASL_JAAS_CONFIG

Config key: sasl.jaas.config

pub fn new(props: &HashMap<String, String>) -> Result<Self, Error>

Creates a ProducerConfig from a map of string key-value pairs.

This is the Rust equivalent of Java’s new ProducerConfig(Map<String, Object>) or new ProducerConfig(Properties). Starts with default values and overrides each field that has a matching entry in the map.

Unknown keys are logged as warnings and ignored, matching Java’s behavior.

Errors

Returns Error::LocalIllegalArgument if a value cannot be parsed for its expected type (e.g., "abc" for an integer field).

pub fn set_partitioner<K: 'static, V: 'static>( self, partitioner: Box<dyn Partitioner<K, V>>, ) -> Self

Sets the Partitioner that determines which partition each record goes to: the value of Java’s partitioner.class.

Java names a class, which the producer instantiates by reflection; here the partitioner itself is the value. KafkaProducer::new configures it with the user configs plus the resolved client.id, as Java does (KafkaProducer.java:381-388), and closes it on close. As with any configured partitioner, adaptive partitioning is then disabled. The producer built from this config takes ownership of the partitioner.

This replaces a partitioner.type given in the properties passed to new, as a later value for the same key would.

The partitioner’s K / V must be the record types of the producer built from this config; otherwise KafkaProducer::new fails with “<partitioner> is not an instance of <expected>”.

Trait Implementations

impl Debug for ProducerConfig

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

Formats the value using the given formatter.

impl Default for ProducerConfig

fn default() -> Self

Returns the “default value” for a type.