diff --git a/src/config.rs b/src/config.rs index 59cca88..ee57160 100644 --- a/src/config.rs +++ b/src/config.rs @@ -73,7 +73,7 @@ fn build_config_std() -> Config { Err(_) => None, }, engine: Engine{ - name: String::from("stdin"), + name: env::var("INPUT_NAME").unwrap_or(String::from("stdin")), kafka: None, device: None, udp: Some(UDP{