Struct ConsumerConfig 

pub struct ConsumerConfig {
    pub topic_id: u32,
    pub max_fetch_bytes: u32,
    pub start_position: SeekPosition,
}

Configuration for a consumer

Fields

topic_id: u32

Topic ID to consume from

max_fetch_bytes: u32

Maximum bytes to fetch per poll (default: 64KB)

start_position: SeekPosition

Starting position (default: Beginning)

Implementations

impl ConsumerConfig

pub fn new(topic_id: u32) -> Self

Create a new consumer configuration for the specified topic

pub fn with_max_fetch_bytes(self, bytes: u32) -> Self

Set the maximum bytes to fetch per poll operation

pub fn with_start_position(self, position: SeekPosition) -> Self

Set the starting position for consumption

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.

impl Default for ConsumerConfig

fn default() -> Self

Returns the “default value” for a type.