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,