Struct StreamingConsumerConfig 

pub struct StreamingConsumerConfig {
    pub topic_id: u32,
    pub max_batch_bytes: u32,
    pub start_position: SeekPosition,
    pub consumer_group: Option<String>,
    pub auto_commit_interval_ms: u64,
}

Configuration for a streaming consumer

Fields

topic_id: u32

Topic ID to consume from

max_batch_bytes: u32

Maximum bytes per batch (default: 64KB)

start_position: SeekPosition

Starting position (default: Beginning)

consumer_group: Option<String>

Consumer group ID (for offset tracking)

auto_commit_interval_ms: u64

Auto-commit interval in milliseconds (0 = manual commit only)

Implementations

impl StreamingConsumerConfig

pub fn new(topic_id: u32) -> Self

Create a new streaming consumer configuration for the specified topic

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

Set the maximum bytes per batch

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

Set the starting position for consumption

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

Set the consumer group for coordinated consumption

pub fn with_auto_commit_interval(self, interval_ms: u64) -> Self

Set the auto-commit interval in milliseconds (0 = disabled)

Trait Implementations

impl Clone for StreamingConsumerConfig

fn clone(&self) -> StreamingConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingConsumerConfig

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

Formats the value using the given formatter.

impl Default for StreamingConsumerConfig

fn default() -> Self

Returns the “default value” for a type.