From 06956d172da0c93b4c5c819940c7ea00366aed34 Mon Sep 17 00:00:00 2001
From: Felix Kunde <felix-kunde@gmx.de>
Date: Thu, 25 Nov 2021 16:05:48 +0100
Subject: [PATCH] existing slot must use the same plugin

---
 pkg/cluster/streams.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
 		}
 	}