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() }, )