diff --git a/setup/jetstream/nats.go b/setup/jetstream/nats.go
index 3e373530a..64cfccff3 100644
--- a/setup/jetstream/nats.go
+++ b/setup/jetstream/nats.go
@@ -1,6 +1,7 @@
 package jetstream
 
 import (
+	"reflect"
 	"strings"
 	"sync"
 	"time"
@@ -82,6 +83,8 @@ func setupNATS(cfg *config.JetStream, nc *natsclient.Conn) (natsclient.JetStream
 		}
 		if info != nil {
 			switch {
+			case !reflect.DeepEqual(info.Config.Subjects, stream.Subjects):
+				fallthrough
 			case info.Config.Retention != stream.Retention:
 				fallthrough
 			case info.Config.Storage != stream.Storage: