diff --git a/packages/microservices/server/server-nats.ts b/packages/microservices/server/server-nats.ts
index 30ce09280..00787840b 100644
--- a/packages/microservices/server/server-nats.ts
+++ b/packages/microservices/server/server-nats.ts
@@ -123,25 +123,11 @@ export class ServerNats<
 
   public async createNatsClient(): Promise<Client> {
     const natsPackage = await this.loadPackage(
-      'nats',
+      '@nats-io/transport-node',
       ServerNats.name,
-      () => import('nats'),
+      () => import('@nats-io/transport-node'),
     );
 
-    // Eagerly initialize serializer/deserializer so they can be used synchronously
-    if (
-      this.serializer &&
-      typeof (this.serializer as any).init === 'function'
-    ) {
-      await (this.serializer as any).init();
-    }
-    if (
-      this.deserializer &&
-      typeof (this.deserializer as any).init === 'function'
-    ) {
-      await (this.deserializer as any).init();
-    }
-
     const options = this.options || ({} as NatsOptions);
     return natsPackage.connect({
       servers: NATS_DEFAULT_URL,
diff --git a/packages/microservices/test/client/client-nats.spec.ts b/packages/microservices/test/client/client-nats.spec.ts
index 248468186..f45377392 100644
--- a/packages/microservices/test/client/client-nats.spec.ts
+++ b/packages/microservices/test/client/client-nats.spec.ts
@@ -1,4 +1,4 @@
-import { headers as createHeaders } from 'nats';
+import { headers as createHeaders } from '@nats-io/transport-node';
 import { ClientNats } from '../../client/client-nats.js';
 import { ReadPacket, WritePacket } from '../../interfaces/index.js';
 import { NatsRecord } from '../../record-builders/index.js';