We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 396c8db commit 32d0511Copy full SHA for 32d0511
infra/pragma-node/config/.env.example
@@ -2,4 +2,5 @@ DATABASE_URL="postgres://postgres:test-password@db:5432/pragma"
2
DATABASE_MAX_CONN=5
3
TOPIC="pragma-data"
4
HOST="0.0.0.0"
5
-PORT=3000
+PORT=3000
6
+KAFKA_BROKERS="pragma-kafka:9092"
pragma-node/src/infra/kafka/mod.rs
@@ -8,7 +8,7 @@ lazy_static! {
8
let brokers =
9
std::env::var("KAFKA_BROKERS").expect("can't load kafka brokers list from env");
10
ClientConfig::new()
11
- .set("bootstrap.servers", brokers)
+ .set("bootstrap.servers", &brokers)
12
.create()
13
.expect("can't create kafka producer")
14
};
0 commit comments