public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

existing slot must use the same plugin

This commit is contained in:
Felix Kunde 2021-11-25 16:05:48 +01:00
parent 8d52e8d3c6
commit 06956d172d
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/cluster/streams.go
View File

@ -203,7 +203,7 @@ func (c *Cluster) getStreamConnection(database, user string) zalandov1alpha1.Con
func (c *Cluster) getLogicalReplicationSlot(database string) string { func (c *Cluster) getLogicalReplicationSlot(database string) string {
for slotName, slot := range c.Spec.Patroni.Slots { 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 return slotName
} }
} }