yozefu_app/configuration/
consumer_config.rs

1use serde::{Deserialize, Serialize};
2
3/// Configuration for the kafka consumer
4#[derive(Debug, Deserialize, Serialize, PartialEq, Eq, Clone)]
5#[cfg_attr(test, derive(schemars::JsonSchema))]
6pub struct ConsumerConfig {
7    pub buffer_capacity: usize,
8    pub timeout_in_ms: u64,
9}
10
11impl Default for ConsumerConfig {
12    fn default() -> Self {
13        Self {
14            buffer_capacity: 1000,
15            timeout_in_ms: 10,
16        }
17    }
18}