fix: use onApplicationShutdown to disconnect kafka producers

Byndyusoft · Sep 2, 2024 · 19b393a · 19b393a
1 parent cd7bdea
commit 19b393a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/producer/kafkaCoreProducer.ts b/src/producer/kafkaCoreProducer.ts
@@ -17,21 +17,21 @@
 import {
   Inject,
   Injectable,
-  OnModuleDestroy,
+  OnApplicationShutdown,
   OnModuleInit,
 } from "@nestjs/common";
 import { Producer } from "kafkajs";
 
 import { ProducersMapToken } from "../consts";
 
 @Injectable()
-export class KafkaCoreProducer implements OnModuleInit, OnModuleDestroy {
+export class KafkaCoreProducer implements OnModuleInit, OnApplicationShutdown {
   public constructor(
     @Inject(ProducersMapToken)
     private readonly producersMap: Map<string, Producer>,
   ) {}
 
-  public async onModuleDestroy(): Promise<void> {
+  public async onApplicationShutdown(): Promise<void> {
     await Promise.all(
       [...this.producersMap.values()].map((x) => x.disconnect()),
     );