Fix setting placement on stream update (#171)

Signed-off-by: Piotr Piotrowski <[email protected]>
nats-io · Mar 20, 2024 · 8244807 · 8244807
1 parent f0ed8b1
commit 8244807
Showing 1 changed file with 7 additions and 0 deletions.
diff --git 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
 	}