diff --git a/ws-connector/src/components.ts b/ws-connector/src/components.ts
index f02f932..600dd58 100644
--- a/ws-connector/src/components.ts
+++ b/ws-connector/src/components.ts
@@ -1,5 +1,5 @@
 import { HTTPProvider } from 'eth-connect'
-import { createDotEnvConfigComponent } from '@well-known-components/env-config-provider'
+import { createConfigComponent, createDotEnvConfigComponent } from '@well-known-components/env-config-provider'
 import { createLogComponent } from '@well-known-components/logger'
 import { AppComponents } from './types'
 import { metricDeclarations } from './metrics'
@@ -18,7 +18,10 @@ export async function initComponents(): Promise<AppComponents> {
   const server = await createUWsComponent({ config, logs })
 
   const fetch = createFetchComponent()
-  const nats = await createNatsComponent({ config, logs })
+
+  const natsLogs = await createLogComponent({ config: createConfigComponent({ LOG_LEVEL: 'WARN' }) })
+  const nats = await createNatsComponent({ config, logs: natsLogs })
+
   const peersRegistry = await createPeersRegistry()
 
   const ethNetwork = (await config.getString('ETH_NETWORK')) ?? 'sepolia'
diff --git a/ws-connector/src/controllers/handlers/ws-handler.ts b/ws-connector/src/controllers/handlers/ws-handler.ts
index df49300..87ad49e 100644
--- a/ws-connector/src/controllers/handlers/ws-handler.ts
+++ b/ws-connector/src/controllers/handlers/ws-handler.ts
@@ -68,7 +68,7 @@ export async function registerWsHandler(
       try {
         packet = ClientPacket.decode(Buffer.from(message))
       } catch (err: any) {
-        console.log(Buffer.from(message).toString('hex').match(/../g)!.join(' '))
+        logger.log(Buffer.from(message).toString('hex').match(/../g)!.join(' '))
 
         logger.error(err)
         ws.end(1007, Buffer.from('Cannot decode ClientPacket'))