diff --git a/pkg/cluster/streams.go b/pkg/cluster/streams.go index 3b5134dba..b00b6d09c 100644 --- a/pkg/cluster/streams.go +++ b/pkg/cluster/streams.go @@ -203,7 +203,7 @@ func (c *Cluster) getStreamConnection(database, user string) zalandov1alpha1.Con func (c *Cluster) getLogicalReplicationSlot(database string) string { for slotName, slot := range c.Spec.Patroni.Slots { - if slot["type"] == "logical" && slot["database"] == database { + if slot["type"] == "logical" && slot["database"] == database && slot["plugin"] == "wal2json" { return slotName } }