kafka/consumer/
config.rs

1use crate::client::FetchOffset;
2
3#[derive(Debug)]
4pub struct Config {
5    pub group: String,
6    pub fallback_offset: FetchOffset,
7    pub retry_max_bytes_limit: i32,
8}