Struct WorkerConfig 

pub struct WorkerConfig {
    pub worker_id: String,
    pub max_fetch_bytes: u32,
    pub heartbeat_interval: Duration,
    pub offset_dir: Option<PathBuf>,
    pub start_position: SeekPosition,
}

Configuration for a grouped consumer (worker)

Fields

worker_id: String

Unique identifier for this worker

max_fetch_bytes: u32

Maximum bytes to fetch per poll

heartbeat_interval: Duration

Heartbeat interval

offset_dir: Option<PathBuf>

Offset storage directory

start_position: SeekPosition

Starting position for new topics

Implementations

impl WorkerConfig

pub fn new(worker_id: impl Into<String>) -> Self

Create a new worker configuration

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

Set max fetch bytes

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

Set heartbeat interval

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

Set offset storage directory

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

Set starting position

Trait Implementations

impl Clone for WorkerConfig

fn clone(&self) -> WorkerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerConfig

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

Formats the value using the given formatter.