diff --git a/libs/nats/src/consumer.nats.service.ts b/libs/nats/src/consumer.nats.service.ts
index 88157ea13db32fc6687e64595d2b903f688160c2..8cef00f874090de467de8a84d94c1cfb6fb48fcd 100644
--- a/libs/nats/src/consumer.nats.service.ts
+++ b/libs/nats/src/consumer.nats.service.ts
@@ -38,7 +38,7 @@ export class ConsumerService extends NatsBaseService {
 
       return this.jsClient.consumers.get(stream, consumerConfig.name);
     } catch (error) {
-      if (error instanceof NatsError && error.code === "409") {
+      if (error instanceof NatsError && error.api_error?.err_code === 10065) {
         this.logger.log("Stream already exists");
         return this.jsClient.consumers.get(stream, consumerConfig.name);
       }