diff --git a/controllers/jetstream/stream.go b/controllers/jetstream/stream.go index f87277c8..5c5844cb 100644 --- a/controllers/jetstream/stream.go +++ b/controllers/jetstream/stream.go @@ -514,6 +514,13 @@ func updateStream(ctx context.Context, c jsmClient, spec apis.StreamSpec) (err e config.Sources[i] = jss } + if spec.Placement != nil { + config.Placement = &jsmapi.Placement{ + Cluster: spec.Placement.Cluster, + Tags: spec.Placement.Tags, + } + } + if spec.Metadata != nil { config.Metadata = spec.Metadata }