From 2cf7fe2809a9e70ce75d2dbd1af0602bfb5eb109 Mon Sep 17 00:00:00 2001
From: Felix Kunde <felix-kunde@gmx.de>
Date: Fri, 27 Jan 2023 17:36:58 +0100
Subject: [PATCH] fix sync of stream slots

---
 pkg/cluster/sync.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go
index 477cbdc75..ecdda6998 100644
--- a/pkg/cluster/sync.go
+++ b/pkg/cluster/sync.go
@@ -647,7 +647,12 @@ func (c *Cluster) checkAndSetGlobalPostgreSQLConfiguration(pod *v1.Pod, effectiv
 			}
 		}
 		slotsToSet[slotName] = desiredSlot
-		c.replicationSlots[slotName] = desiredSlot
+		// only add slots specified in manifest to c.replicationSlots
+		for manifestSlotName, _ := range c.Spec.Patroni.Slots {
+			if manifestSlotName == slotName {
+				c.replicationSlots[slotName] = desiredSlot
+			}
+		}
 	}
 	if len(slotsToSet) > 0 {
 		configToSet["slots"] = slotsToSet