Struct ConsumerConfig 

pub struct ConsumerConfig {

    pub bootstrap_servers: Vec<String>,
    pub group_id: String,
    pub topics: Vec<String>,
    pub partitions: HashMap<String, Vec<u32>>,
    pub max_poll_records: u32,
    pub max_poll_interval_ms: u64,
    pub auto_commit_interval: Option<Duration>,
    pub isolation_level: u8,
    pub auth: Option<ConsumerAuthConfig>,
    pub metadata_refresh_interval: Duration,
    pub reconnect_backoff_ms: u64,
    pub reconnect_backoff_max_ms: u64,
    pub max_reconnect_attempts: u32,
    pub session_timeout_ms: u32,
    pub rebalance_timeout_ms: u32,
    pub heartbeat_interval_ms: u64,
}

Configuration for the high-level consumer.

Fields

bootstrap_servers: Vec<String>

Bootstrap server addresses (host:port).

On initial connect and reconnect, the consumer tries each server in round-robin order until one succeeds. Accepts a single server or multiple for failover.

group_id: String

Consumer group ID for offset management

topics: Vec<String>

Topics to subscribe to

partitions: HashMap<String, Vec<u32>>

Explicit partition assignments (topic → partitions). If empty, all partitions of each subscribed topic are consumed.

max_poll_records: u32

Maximum messages per partition per poll

max_poll_interval_ms: u64

Long-poll wait time in milliseconds (0 = immediate return)

auto_commit_interval: Option<Duration>

Auto-commit interval (None = manual commit only)

isolation_level: u8

Transaction isolation level (0 = read_uncommitted, 1 = read_committed)

auth: Option<ConsumerAuthConfig>

Authentication credentials (optional)

metadata_refresh_interval: Duration

Interval for re-discovering partition assignments (default: 5 min). Set to Duration::MAX to disable periodic re-discovery.

reconnect_backoff_ms: u64

Initial reconnect backoff delay in milliseconds (default: 100)

reconnect_backoff_max_ms: u64

Maximum reconnect backoff delay in milliseconds (default: 10 000)

max_reconnect_attempts: u32

Maximum number of reconnect attempts before giving up (default: 10)

session_timeout_ms: u32

Session timeout for group coordination in milliseconds (default: 10 000). If the coordinator does not receive a heartbeat within this interval, it considers the member dead and triggers a rebalance.

rebalance_timeout_ms: u32

Rebalance timeout in milliseconds (default: 30 000). Maximum time the coordinator waits for all members to join during a rebalance.

heartbeat_interval_ms: u64

Heartbeat interval in milliseconds (default: 3 000). Should be no more than 1/3 of session_timeout_ms.

Implementations

impl ConsumerConfig

pub fn builder() -> ConsumerConfigBuilder

Trait Implementations

impl Clone for ConsumerConfig

fn clone(&self) -> ConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerConfig

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

Formats the value using the given formatter.