Fix nats stream replica update

kyma-project · Nov 15, 2023 · 82aee38 · 82aee38
1 parent 0ec74bd
commit 82aee38
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/controller/eventing/nats.go b/internal/controller/eventing/nats.go
@@ -34,6 +34,10 @@ func (r *Reconciler) reconcileNATSSubManager(ctx context.Context, eventing *v1al
 		if err := r.stopNATSSubManager(false, log); err != nil {
 			return err
 		}
+	} else if eventing.Status.BackendConfigHash != specHash {
+		// in case spec is change and subManager is not started yet (e.g. due to error)
+		// make natsSubManager nil to create a subManager with new values
+		r.natsSubManager = nil
 	}
 
 	if r.natsSubManager == nil {