Type Alias ClientConfig 

pub type ClientConfig = ProducerConfig;

Alias for client config.

Aliased Type

pub struct ClientConfig {

    pub bootstrap_servers: Vec<String>,
    pub client_id: String,
    pub security_protocol: SecurityProtocol,
    pub tls: TlsConfig,
    pub sasl: SaslConfig,
    pub acks: i16,
    pub enable_idempotence: bool,
    pub partitioner: ProducerPartitioner,
    pub compression: ProducerCompression,
    pub batch_size: usize,
    pub buffer_memory: usize,
    pub max_block: Duration,
    pub max_request_size: usize,
    pub partitioner_ignore_keys: bool,
    pub linger: Duration,
    pub delivery_timeout: Duration,
    pub request_timeout: Duration,
    pub metadata_max_age: Duration,
    pub retry_backoff: Duration,
    pub max_retries: usize,
    pub max_in_flight_requests_per_connection: usize,
    pub transactional_id: Option<String>,
    pub transaction_timeout: Duration,
    pub tcp_connector: Arc<dyn TcpConnector>,
}

Fields

bootstrap_servers: Vec<String>

Bootstrap Servers.

client_id: String

Client Id.

security_protocol: SecurityProtocol

Security Protocol.

tls: TlsConfig

Tls.

sasl: SaslConfig

Sasl.

acks: i16

Acks.

enable_idempotence: bool

Enable Idempotence.

partitioner: ProducerPartitioner

Partitioner.

compression: ProducerCompression

Compression.

batch_size: usize

Batch Size.

buffer_memory: usize

Total memory available to buffered producer records.

max_block: Duration

Maximum time producer calls may wait for metadata or buffer capacity.

max_request_size: usize

Maximum serialized Produce request size.

partitioner_ignore_keys: bool

Whether the default partitioner should ignore record keys.

linger: Duration

Linger.

delivery_timeout: Duration

Delivery Timeout.

request_timeout: Duration

Request Timeout.

metadata_max_age: Duration

Metadata Max Age.

retry_backoff: Duration

Retry Backoff.

max_retries: usize

Max Retries.

max_in_flight_requests_per_connection: usize

Max In Flight Requests Per Connection.

transactional_id: Option<String>

Transactional Id.

transaction_timeout: Duration

Transaction Timeout.

tcp_connector: Arc<dyn TcpConnector>

TCP connector.