kommitted 0.1.0

Measure Kafka Consumer Offset Lag and Time Lag
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

pub const LOG_FILTER_ENV_VAR: &str = "KOMMITTED_LOG";

/// Log level will be configured based on the given `verbosity_level`.
///
/// If the env var `KOMMITTED_LOG` is set, that will take precedence and configuration
/// will be based on the rules described [here](https://docs.rs/env_logger/latest/env_logger/#enabling-logging).
pub fn init(verbosity_level: i8) {
    let default_log_level = match verbosity_level {
        i8::MIN..=-2 => "OFF",
        -1 => log::Level::Error.as_str(),
        0 => log::Level::Warn.as_str(),
        1 => log::Level::Info.as_str(),
        2 => log::Level::Debug.as_str(),
        3..=i8::MAX => log::Level::Trace.as_str(),
    };

    let logger_env = env_logger::Env::default().filter_or(LOG_FILTER_ENV_VAR, default_log_level);
    let mut logger_builder = env_logger::Builder::from_env(logger_env);
    logger_builder.init();

    info!("Configured log level: {}", log::max_level().as_str());
}