From 02c93f7db1a4fccff093d3274e4938cd3314d45d Mon Sep 17 00:00:00 2001 From: chanyeong Date: Fri, 30 Aug 2024 11:21:02 +0900 Subject: [PATCH] =?UTF-8?q?fix:=20bucket=20name=20vault=EB=A1=9C=20?= =?UTF-8?q?=EC=9D=B4=EB=8F=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .env | 2 -- src/kafka/kafka.service.ts | 6 +----- 2 files changed, 1 insertion(+), 7 deletions(-) diff --git a/.env b/.env index b845dfd..18e9565 100644 --- a/.env +++ b/.env @@ -1,5 +1,3 @@ -MINIO_BUCKET_NAME="ice-grad-pdf" - TOPIC="pdf-topic" CONSUMER_GROUP="icc-grad-consumer-group" KAFKA_CLIENT_BOOTSTRAP_SERVER="kafka.kafka.svc.cluster.local:9092" diff --git a/src/kafka/kafka.service.ts b/src/kafka/kafka.service.ts index 22aaef8..eb5ca10 100644 --- a/src/kafka/kafka.service.ts +++ b/src/kafka/kafka.service.ts @@ -20,11 +20,7 @@ export class KafkaService implements OnModuleInit, OnModuleDestroy { ) { this.kafka = new Kafka({ clientId: `${process.env.CONSUMER_GROUP}+${process.pid}`, - brokers: [ - 'kafka-controller-0.kafka-controller-headless.kafka.svc.cluster.local:9092', - 'kafka-controller-1.kafka-controller-headless.kafka.svc.cluster.local:9092', - 'kafka-controller-2.kafka-controller-headless.kafka.svc.cluster.local:9092', - ], + brokers: ['kafka.kafka.svc.cluster.local:9092'], sasl: { mechanism: 'scram-sha-256', username: process.env.SASL_USER,