@@ -238,15 +238,10 @@ func (r *InstanceReconciler) Reconcile(
 }
 
 func (r *InstanceReconciler) configureSlotReplicator(cluster *apiv1.Cluster) {
-	// If PostgreSQL is older than 11 never start the SlotReplicator
-	psqlVersion, err := cluster.GetPostgresqlVersion()
-	if err != nil || psqlVersion < 110000 {
+	switch r.instance.PodName {
+	case cluster.Status.CurrentPrimary, cluster.Status.TargetPrimary:
 		r.instance.ConfigureSlotReplicator(nil)
-	}
-
-	if cluster.Status.CurrentPrimary == r.instance.PodName || cluster.Status.TargetPrimary == r.instance.PodName {
-		r.instance.ConfigureSlotReplicator(nil)
-	} else {
+	default:
 		r.instance.ConfigureSlotReplicator(cluster.Spec.ReplicationSlots)
 	}
 }
Original file line number	Diff line number	Diff line change
`@@ -238,15 +238,10 @@ func (r *InstanceReconciler) Reconcile(`
`238`	`238`	`}`
`239`	`239`
`240`	`240`	`func (r InstanceReconciler) configureSlotReplicator(cluster apiv1.Cluster) {`
`241`		`- // If PostgreSQL is older than 11 never start the SlotReplicator`
`242`		`- psqlVersion, err := cluster.GetPostgresqlVersion()`
`243`		`- if err != nil \|\| psqlVersion < 110000 {`
	`241`	`+ switch r.instance.PodName {`
	`242`	`+ case cluster.Status.CurrentPrimary, cluster.Status.TargetPrimary:`
`244`	`243`	`r.instance.ConfigureSlotReplicator(nil)`
`245`		`- }`
`246`		`-`
`247`		`- if cluster.Status.CurrentPrimary == r.instance.PodName \|\| cluster.Status.TargetPrimary == r.instance.PodName {`
`248`		`- r.instance.ConfigureSlotReplicator(nil)`
`249`		`- } else {`
	`244`	`+ default:`
`250`	`245`	`r.instance.ConfigureSlotReplicator(cluster.Spec.ReplicationSlots)`
`251`	`246`	`}`
`252`	`247`	`}`