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