kafka/consumer/
config.rs

1
2
3
4
5
6
7
8
use crate::client::FetchOffset;

#[derive(Debug)]
pub struct Config {
    pub group: String,
    pub fallback_offset: FetchOffset,
    pub retry_max_bytes_limit: i32,
}