fix: onApplicationBootStrap

SystemConsultantGroup · Aug 29, 2024 · 44fbadf · 44fbadf
1 parent af03ca0
commit 44fbadf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/kafka/kafka.service.ts b/src/kafka/kafka.service.ts
@@ -33,10 +33,10 @@ export class KafkaService implements OnApplicationBootstrap, OnModuleDestroy {
     this.consumer = this.kafka.consumer({
       groupId: process.env.CONSUMER_GROUP,
     });
-    this.consumer.connect();
   }
 
   async onApplicationBootstrap() {
+    await this.consumer.connect();
     await this.consumer.subscribe({ topic: this.topic, fromBeginning: false });
     await this.consumer
       .run({