diff --git a/server/stream.go b/server/stream.go
index e6f5f9287ce..12b0339b445 100644
--- a/server/stream.go
+++ b/server/stream.go
@@ -2895,7 +2895,9 @@ func (mset *stream) setSourceConsumer(iname string, seq uint64, startTime time.T
 		subject = fmt.Sprintf(JSApiConsumerCreateExT, si.name, req.Config.Name, req.Config.FilterSubject)
 	} else if len(req.Config.FilterSubjects) == 1 {
 		req.Config.Name = fmt.Sprintf("src-%s", createConsumerName())
-		subject = fmt.Sprintf(JSApiConsumerCreateExT, si.name, req.Config.Name, req.Config.FilterSubjects[0])
+		req.Config.FilterSubject = req.Config.FilterSubjects[0]
+		req.Config.FilterSubjects = []string{}
+		subject = fmt.Sprintf(JSApiConsumerCreateExT, si.name, req.Config.Name, req.Config.FilterSubject)
 	} else {
 		subject = fmt.Sprintf(JSApiConsumerCreateT, si.name)
 	}