diff --git a/menuflow/events/nats_publisher.py b/menuflow/events/nats_publisher.py
index 2182400..8301251 100644
--- a/menuflow/events/nats_publisher.py
+++ b/menuflow/events/nats_publisher.py
@@ -34,7 +34,11 @@ async def get_connection(cls) -> tuple[NATSClient, JetStreamContext]:
     async def nats_jetstream_connection(cls) -> JetStreamContext:
         log.info("Connecting to NATS JetStream")
         nc: NATSClient = await nats_connect(
-            cls.config["nats.address"], allow_reconnect=False, max_reconnect_attempts=1
+            cls.config["nats.address"],
+            allow_reconnect=False,
+            max_reconnect_attempts=1,
+            user=cls.config["nats.user"],
+            password=cls.config["nats.password"],
         )
         js = nc.jetstream()
         subject = f"{cls.config['nats.subject']}.*"