From c05d16a91ace10bd8288fd56c786a80f9f96d84d Mon Sep 17 00:00:00 2001 From: Rishi Ghan Date: Mon, 24 Feb 2025 14:02:18 -0500 Subject: [PATCH] =?UTF-8?q?=F0=9F=AA=B3=20Updated=20kafka=20broker=20uri?= =?UTF-8?q?=20to=20be=20dynamic?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/autodownload.service.ts | 2 +- services/comicprocessor.service.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/services/autodownload.service.ts b/services/autodownload.service.ts index 76d1c26..44b2ecc 100644 --- a/services/autodownload.service.ts +++ b/services/autodownload.service.ts @@ -99,7 +99,7 @@ export default class AutoDownloadService extends Service { async started() { const kafka = new Kafka({ clientId: "comic-search-service", - brokers: ["localhost:9092"], + brokers: [process.env.KAFKA_BROKER_URI], }); this.kafkaProducer = kafka.producer(); await this.kafkaProducer.connect(); diff --git a/services/comicprocessor.service.ts b/services/comicprocessor.service.ts index 4ec10a9..b01548d 100644 --- a/services/comicprocessor.service.ts +++ b/services/comicprocessor.service.ts @@ -196,7 +196,7 @@ export default class ComicProcessorService extends Service { async started() { const kafka = new Kafka({ clientId: "comic-processor-service", - brokers: ["localhost:9092"], + brokers: [process.env.KAFKA_BROKER_URI], logLevel: logLevel.INFO, }); this.kafkaConsumer = kafka.consumer({ groupId: "comic-processor-group" });