From a4377fe209d40e6986b601002616f54c57570844 Mon Sep 17 00:00:00 2001
From: Gabriel Kaszewski <gabrielkaszewski@gmail.com>
Date: Thu, 14 May 2026 23:29:45 +0200
Subject: [PATCH] fix(nats): remove filter_subject from consumer config

---
 crates/adapters/nats/src/lib.rs | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/crates/adapters/nats/src/lib.rs b/crates/adapters/nats/src/lib.rs
index bf253a2..2b65d18 100644
--- a/crates/adapters/nats/src/lib.rs
+++ b/crates/adapters/nats/src/lib.rs
@@ -121,7 +121,9 @@ impl MessageSource for NatsMessageSource {
                     CONSUMER_NAME,
                     jetstream::consumer::pull::Config {
                         durable_name: Some(CONSUMER_NAME.to_string()),
-                        filter_subject: STREAM_SUBJECT.to_string(),
+                        // No filter_subject — consume everything from the stream.
+                        // filter_subject matching the stream's own wildcard can be
+                        // inconsistent across NATS server versions.
                         ..Default::default()
                     },
                 )