From 14e989ac839780dd973757f510799f764bc92757 Mon Sep 17 00:00:00 2001
From: Felix Kunde <felix-kunde@gmx.de>
Date: Tue, 10 Aug 2021 11:56:15 +0200
Subject: [PATCH] update log messages

---
 pkg/cluster/streams.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pkg/cluster/streams.go b/pkg/cluster/streams.go
index 8bc3129d8..bbfe17eca 100644
--- a/pkg/cluster/streams.go
+++ b/pkg/cluster/streams.go
@@ -236,7 +236,7 @@ func (c *Cluster) syncStreams() error {
 
 	err := c.syncPostgresConfig()
 	if err != nil {
-		return fmt.Errorf("logical decoding setup incomplete: %v", err)
+		return fmt.Errorf("could not update Postgres config for event streaming: %v", err)
 	}
 
 	effectiveStreams, err := c.KubeClient.FabricEventStreamsGetter.FabricEventStreams(c.Namespace).Get(context.TODO(), c.Name+constants.FESsuffix, metav1.GetOptions{})
@@ -253,7 +253,7 @@ func (c *Cluster) syncStreams() error {
 	} else {
 		err := c.syncStreamDbResources()
 		if err != nil {
-			return fmt.Warnf("database setup incomplete: %v", err)
+			c.logger.Warnf("database setup might be incomplete : %v", err)
 		}
 		desiredStreams := c.generateFabricEventStream()
 		if reflect.DeepEqual(effectiveStreams.Spec, desiredStreams.Spec) {