Skip to main content

ClientConfig

kafkit_client

Type Alias ClientConfig 

Source 
pub type ClientConfig = ProducerConfig;
Expand description

Alias for client config.

Aliased Type§

pub struct ClientConfig {
Show 24 fields
    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.