fix: add logging

SystemConsultantGroup · Aug 29, 2024 · fd07beb · fd07beb
1 parent 077ffad
commit fd07beb
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/src/kafka/kafka.service.ts b/src/kafka/kafka.service.ts
@@ -10,7 +10,7 @@ import { PuppeteerService } from '../puppeteer/puppeteer.service';
 import { MinioService } from '../minio/minio.service';
 
 @Injectable()
-export class KafkaService implements OnApplicationBootstrap, OnModuleDestroy {
+export class KafkaService implements OnModuleInit, OnModuleDestroy {
   private kafka: Kafka;
   private consumer: Consumer;
   private topic = process.env.TOPIC;
@@ -27,7 +27,6 @@ export class KafkaService implements OnApplicationBootstrap, OnModuleDestroy {
         'kafka-controller-2.kafka-controller-headless.kafka.svc.cluster.local:9092',
       ],
       sasl: {
-        // mechanism: `process.env.SASL_MECHANISM`,
         mechanism: 'scram-sha-256',
         username: process.env.SASL_USER,
         password: process.env.SASL_PASSWORD,
@@ -39,9 +38,11 @@ export class KafkaService implements OnApplicationBootstrap, OnModuleDestroy {
     });
   }
 
-  async onApplicationBootstrap() {
+  async onModuleInit() {
     await this.consumer.connect();
+    console.log('connected');
     await this.consumer.subscribe({ topic: this.topic, fromBeginning: false });
+    console.log('subsribed');
     await this.consumer
       .run({
         autoCommit: false,

diff --git a/src/main.ts b/src/main.ts
@@ -4,6 +4,6 @@ import { AppModule } from './app.module';
 async function bootstrap() {
   const app = await NestFactory.create(AppModule);
   app.enableShutdownHooks();
-  await app.listen(5000);
+  await app.listen(4000);
 }
 bootstrap();