Struct StandaloneConfig 

pub struct StandaloneConfig {
    pub consumer_id: String,
    pub topic_id: u32,
    pub max_fetch_bytes: u32,
    pub start_position: SeekPosition,
    pub offset_dir: Option<PathBuf>,
    pub auto_commit_interval: Option<Duration>,
    pub connect_timeout: Duration,
    pub poll_timeout: Duration,
}

Configuration for standalone consumer mode

Fields

consumer_id: String

Identifier for this consumer (used for offset storage)

topic_id: u32

Topic ID to consume from

max_fetch_bytes: u32

Maximum bytes to fetch per poll

start_position: SeekPosition

Starting position if no stored offset exists

offset_dir: Option<PathBuf>

Directory for offset persistence (None = in-memory only)

auto_commit_interval: Option<Duration>

Auto-commit interval (None = manual commit only)

connect_timeout: Duration

Connection timeout

poll_timeout: Duration

Poll timeout for blocking operations

Implementations

impl StandaloneConfig

pub fn new(consumer_id: impl Into<String>, topic_id: u32) -> Self

Create a new standalone config for the given topic

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

Set the consumer ID for offset tracking

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

Set the maximum bytes to fetch per poll

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

Set the starting position when no stored offset exists

pub fn with_offset_dir(self, dir: &Path) -> Self

Set the directory for offset persistence If not set, offsets are stored in memory only (lost on restart)

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

Set auto-commit interval (None to disable auto-commit)

pub fn with_manual_commit(self) -> Self

Disable auto-commit (manual commit only)

pub fn with_connect_timeout(self, timeout: Duration) -> Self

Set connection timeout

pub fn with_poll_timeout(self, timeout: Duration) -> Self

Set poll timeout

Trait Implementations

impl Clone for StandaloneConfig

fn clone(&self) -> StandaloneConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StandaloneConfig

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

Formats the value using the given formatter.