From eb51428a4491e0f989583ec7c030bada3a233ad3 Mon Sep 17 00:00:00 2001
From: Felix Kunde <felix-kunde@gmx.de>
Date: Tue, 25 Jan 2022 18:57:55 +0100
Subject: [PATCH] quotes for schema and table

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

diff --git a/pkg/cluster/streams.go b/pkg/cluster/streams.go
index dd126df0f..ea8381eee 100644
--- a/pkg/cluster/streams.go
+++ b/pkg/cluster/streams.go
@@ -141,7 +141,8 @@ func (c *Cluster) syncPostgresConfig() error {
 		tableNames := make([]string, len(tables))
 		i := 0
 		for t := range tables {
-			tableNames[i] = fmt.Sprintf("%q", t)
+			tableName, schemaName := getTableSchema(t)
+			tableNames[i] = fmt.Sprintf("%q.%q", schemaName, tableName)
 			i++
 		}
 		tableList := strings.Join(tableNames, ", ")