feat: kafka sasl 설정 추가

SystemConsultantGroup · Aug 29, 2024 · 080fbd9 · 080fbd9
1 parent 352950f
commit 080fbd9
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/kafka/kafka.service.ts b/src/kafka/kafka.service.ts
@@ -21,6 +21,12 @@ export class KafkaService implements OnModuleInit, OnModuleDestroy {
     this.kafka = new Kafka({
       clientId: `${process.env.CONSUMER_GROUP}+${process.pid}`,
       brokers: [process.env.KAFKA_CLIENT_BOOTSTRAP_SERVER],
+      sasl: {
+        // mechanism: `process.env.SASL_MECHANISM`,
+        mechanism: 'scram-sha-256',
+        username: process.env.SASL_USER,
+        password: process.env.SASL_PASSWORD,
+      },
     });
   }