From a620c8744fce87cfda83cd0978a028ef398ee651 Mon Sep 17 00:00:00 2001 From: Xavier Vello Date: Mon, 23 Oct 2023 16:41:43 +0200 Subject: [PATCH] align envvars with plugin-server --- capture-server/src/main.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/capture-server/src/main.rs b/capture-server/src/main.rs index 9d60f89..1a78f22 100644 --- a/capture-server/src/main.rs +++ b/capture-server/src/main.rs @@ -25,7 +25,8 @@ async fn shutdown() { async fn main() { let use_print_sink = env::var("PRINT_SINK").is_ok(); let address = env::var("ADDRESS").unwrap_or(String::from("127.0.0.1:3000")); - let redis_addr = env::var("REDIS").expect("redis required; please set the REDIS env var"); + let redis_addr = + env::var("REDIS_URL").expect("redis required; please set the REDIS_URL env var"); let redis_client = Arc::new(RedisClient::new(redis_addr).expect("failed to create redis client")); @@ -42,7 +43,7 @@ async fn main() { true, ) } else { - let brokers = env::var("KAFKA_BROKERS").expect("Expected KAFKA_BROKERS"); + let brokers = env::var("KAFKA_HOSTS").expect("Expected KAFKA_HOSTS"); let topic = env::var("KAFKA_TOPIC").expect("Expected KAFKA_TOPIC"); let sink = sink::KafkaSink::new(topic, brokers).unwrap();