🪳 Updated kafka broker uri to be dynamic

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();

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" });