Struct ConsumerConfig 

pub struct ConsumerConfig {
    pub name: String,
    pub max_batch_size: usize,
    pub max_batch_latency: Duration,
    pub checkpoint_name: Option<String>,
    pub filter: Option<Box<dyn Fn(&Value) -> Result<bool> + Send>>,
}

Per-consumer batching, checkpoint, and filter configuration.

Fields

name: String

A name that identifies this consumer. Returned by LogBatch::consumer_name.

max_batch_size: usize

Maximum number of records per batch.

max_batch_latency: Duration

Maximum time to wait for a partial batch to fill before yielding it.

checkpoint_name: Option<String>

If set, enables checkpoint persistence with this name. The checkpoint file will be stored as .<name> in the log directory.

filter: Option<Box<dyn Fn(&Value) -> Result<bool> + Send>>

Optional filter applied to each record. If the filter returns Ok(false) the record is not added to this consumer’s batch.

Implementations

impl ConsumerConfig

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

pub fn max_batch_size(self, size: usize) -> Self

pub fn max_batch_latency(self, latency: Duration) -> Self

pub fn checkpoint_name(self, name: impl Into<String>) -> Self

pub fn filter<F>(self, f: F) -> Self

where F: Fn(&Value) -> Result<bool> + Send + 'static,