Struct GroupConfig 

pub struct GroupConfig {
    pub group_id: String,
    pub topics: Vec<u32>,
    pub assignment_strategy: AssignmentStrategy,
    pub heartbeat_interval: Duration,
    pub session_timeout: Duration,
    pub coordinator_addr: SocketAddr,
    pub server_addr: String,
    pub offset_dir: Option<PathBuf>,
}

Configuration for the group coordinator

Fields

group_id: String

Unique identifier for this consumer group

topics: Vec<u32>

Topics to consume (if empty, discovers from server)

assignment_strategy: AssignmentStrategy

Assignment strategy

heartbeat_interval: Duration

How often workers must send heartbeat

session_timeout: Duration

How long before a worker is considered dead

coordinator_addr: SocketAddr

Address for the coordinator to listen on

server_addr: String

LANCE server address for topic discovery

offset_dir: Option<PathBuf>

Offset storage directory

Implementations

impl GroupConfig

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

Create a new group configuration

pub fn with_topics(self, topics: Vec<u32>) -> Self

Set topics to consume

pub fn with_assignment_strategy(self, strategy: AssignmentStrategy) -> Self

Set the assignment strategy

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

Set heartbeat interval

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

Set session timeout

pub fn with_coordinator_addr(self, addr: SocketAddr) -> Self

Set coordinator listen address

pub fn with_server_addr(self, addr: impl Into<String>) -> Self

Set LANCE server address

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

Set offset storage directory

Trait Implementations

impl Clone for GroupConfig

fn clone(&self) -> GroupConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GroupConfig

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

Formats the value using the given formatter.