Struct ConsumerConfig 

pub struct ConsumerConfig {
    pub bootstrap_servers: Vec<String>,
    pub topic: String,
    pub partition: u32,
    pub initial_offset: u64,
    pub max_bytes: u32,
    pub max_wait_ms: u32,
    pub token: Option<String>,
    pub connect_timeout: Duration,
    pub backoff_on_empty: Duration,
}

Configuration options for an AeroStream consumer.

Fields

bootstrap_servers: Vec<String>

Broker endpoint addresses.

topic: String

Target topic to subscribe to.

partition: u32

Target partition to consume from.

initial_offset: u64

Starting offset for consumption.

max_bytes: u32

Maximum bytes per fetch request.

max_wait_ms: u32

Maximum long-poll wait time on broker in milliseconds.

token: Option<String>

Optional authentication bearer token.

connect_timeout: Duration

Connection timeout.

backoff_on_empty: Duration

Poll retry backoff duration when empty or broker throttles.

Implementations

impl ConsumerConfig

pub fn builder() -> ConsumerConfigBuilder

Create a fluent builder for ConsumerConfig.

Trait Implementations

impl Clone for ConsumerConfig

fn clone(&self) -> Self

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.

impl Default for ConsumerConfig

fn default() -> Self

Returns the “default value” for a type.