diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs
index e953d0f54..d95be8209 100644
--- a/async-nats/src/jetstream/context.rs
+++ b/async-nats/src/jetstream/context.rs
@@ -893,6 +893,7 @@ impl Context {
                 num_replicas: config.num_replicas,
                 discard: DiscardPolicy::New,
                 allow_rollup: true,
+                allow_direct: true,
                 ..Default::default()
             })
             .await?;