summa 0.8.8

Fast full-text search server
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use crate::errors::SummaResult;
use serde::{Deserialize, Serialize};

#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct ConsumerConfig {
    pub bootstrap_servers: Vec<String>,
    pub create_topics: bool,
    pub delete_topics: bool,
    pub group_id: String,
    pub max_poll_interval_ms: u32,
    pub session_timeout_ms: u32,
    pub topics: Vec<String>,
    pub threads: u32,
}

impl ConsumerConfig {
    pub fn new(bootstrap_servers: &[String], group_id: &str, mut threads: u32, topics: &[String]) -> SummaResult<ConsumerConfig> {
        if threads == 0 {
            threads = 1;
        }
        Ok(ConsumerConfig {
            bootstrap_servers: bootstrap_servers.to_owned(),
            create_topics: true,
            delete_topics: true,
            group_id: group_id.to_owned(),
            max_poll_interval_ms: 1800000,
            session_timeout_ms: 300000,
            threads,
            topics: topics.to_owned(),
        })
    }
}