From 0554f59e1f69acfc9a1a03ec34b90dfd3c4ca0d1 Mon Sep 17 00:00:00 2001 From: "CHIEFSOFT\\ameye" Date: Sat, 6 Jul 2024 12:05:27 -0400 Subject: [PATCH] kafka config --- .env | 1 + app/kconfig.js | 5 +++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/.env b/.env index 4b80416..991a031 100644 --- a/.env +++ b/.env @@ -1,2 +1,3 @@ WRENCHJOB_PORT=3000 WRENCHJOB_POSTGRE_URL='postgresql://wrenchboard:wrenchboard@10.20.30.60:5432/wrenchboard' +WRENCHJOB_KAFKA_SERVER='10.10.10.120:9092' diff --git a/app/kconfig.js b/app/kconfig.js index 16d5de8..8c90875 100644 --- a/app/kconfig.js +++ b/app/kconfig.js @@ -1,9 +1,10 @@ // import { Kafka } from "kafkajs"; const {Kafka} = require('kafkajs'); +const kafkaServer = process.env.KAFKA_SERVER; const kafka = new Kafka({ - clientId: "nodejs-kafka", - brokers: ["10.10.10.120:9092"], + clientId: "wallet-kafka", + brokers: [kafkaServer], }); class KafkaConfig { constructor() {