kafka error filtertry catch

Author: andrechristikan

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ack-nestjs-boilerplate-kafka",
-  "version": "3.3.2",
+  "version": "3.3.3",
   "description": "Ack NestJs Boilerplate Kafka",
   "repository": {
     "type": "git",

src/kafka/error/filters/kafka.error.filter.ts

@@ -19,15 +19,17 @@ export class KafkaErrorFilter implements RpcExceptionFilter<RpcException> {
         const { key } = ctx.getContext<KafkaContext>().getMessage();
 
         // Debugger
-        this.debuggerService.error(
-            key ? key.toString() : KafkaErrorFilter.name,
-            {
-                description: exception.message,
-                class: __class,
-                function: __function,
-            },
-            exception
-        );
+        try {
+            this.debuggerService.error(
+                key ? key.toString() : KafkaErrorFilter.name,
+                {
+                    description: exception.message,
+                    class: __class,
+                    function: __function,
+                },
+                exception
+            );
+        } catch (err: unknown) {}
 
         return of(JSON.stringify({ error: exception.getError() }));
     }