Struct ConsumerConfigBuilder 

pub struct ConsumerConfigBuilder { /* private fields */ }

Builder for ConsumerConfig.

Implementations

impl ConsumerConfigBuilder

pub fn new() -> Self

pub fn bootstrap_server(self, server: impl Into<String>) -> Self

Set a single bootstrap server (convenience for bootstrap_servers).

pub fn bootstrap_servers(self, servers: Vec<String>) -> Self

Set multiple bootstrap servers for failover.

pub fn group_id(self, group: impl Into<String>) -> Self

pub fn topics(self, topics: Vec<String>) -> Self

pub fn topic(self, topic: impl Into<String>) -> Self

pub fn assign(self, topic: impl Into<String>, partitions: Vec<u32>) -> Self

Assign specific partitions for a topic (static assignment).

pub fn max_poll_records(self, n: u32) -> Self

pub fn max_poll_interval_ms(self, ms: u64) -> Self

pub fn auto_commit_interval(self, interval: Option<Duration>) -> Self

pub fn enable_auto_commit(self, enabled: bool) -> Self

pub fn isolation_level(self, level: u8) -> Self

pub fn read_committed(self) -> Self

Use read_committed isolation (only see committed transactional messages).

pub fn auth( self, username: impl Into<String>, password: impl Into<String>, ) -> Self

pub fn metadata_refresh_interval(self, interval: Duration) -> Self

Set the interval for periodic partition re-discovery.

pub fn reconnect_backoff_ms(self, ms: u64) -> Self

Set initial reconnect backoff delay in milliseconds.

pub fn reconnect_backoff_max_ms(self, ms: u64) -> Self

Set maximum reconnect backoff delay in milliseconds.

pub fn max_reconnect_attempts(self, attempts: u32) -> Self

Set maximum number of reconnect attempts (default: 10).

pub fn session_timeout_ms(self, ms: u32) -> Self

Set session timeout for group coordination (default: 10 000 ms).

pub fn rebalance_timeout_ms(self, ms: u32) -> Self

Set rebalance timeout (default: 30 000 ms).

pub fn heartbeat_interval_ms(self, ms: u64) -> Self

Set heartbeat interval (default: 3 000 ms, should be ≤ 1/3 of session timeout).

pub fn build(self) -> ConsumerConfig

Trait Implementations

impl Default for ConsumerConfigBuilder

fn default() -> Self

Returns the “default value” for a type.