diff --git a/internal/adapters/natsadapter/natsadapter.go b/internal/adapters/natsadapter/natsadapter.go
index 0e030ff..458c7fb 100644
--- a/internal/adapters/natsadapter/natsadapter.go
+++ b/internal/adapters/natsadapter/natsadapter.go
@@ -26,10 +26,11 @@ func New(natsc *nats.Conn) (*NatsAdapter, error) {
 		return nil, fmt.Errorf("create jetstream: %w", err)
 	}
 	jstream, err := jets.CreateStream(context.TODO(), jetstream.StreamConfig{
-		Name:       StreamName,
-		Subjects:   []string{fmt.Sprintf("%s.>", SubjectPrefix)},
-		Retention:  jetstream.WorkQueuePolicy,
-		Duplicates: DedupWindow,
+		Name:        StreamName,
+		Subjects:    []string{fmt.Sprintf("%s.>", SubjectPrefix)},
+		Retention:   jetstream.WorkQueuePolicy,
+		Duplicates:  DedupWindow,
+		AllowDirect: true,
 	})
 	if err != nil {
 		return nil, fmt.Errorf("create js stream: %w", err)