diff --git a/jetstream/jetstream.go b/jetstream/jetstream.go index eadd3e69c..f90340176 100644 --- a/jetstream/jetstream.go +++ b/jetstream/jetstream.go @@ -369,7 +369,7 @@ func (js *jetStream) CreateStream(ctx context.Context, cfg StreamConfig) (Stream } for i := range cfg.Sources { if len(cfg.Sources[i].SubjectTransforms) != 0 && len(resp.Sources[i].SubjectTransforms) == 0 { - return nil, ErrStreamSourceMultipleFilterSubjectsNotSupported + return nil, ErrStreamSubjectTransformNotSupported } } }