From 795cd5d4ec3bf5f612aff62b3c52e8a2d50997ba Mon Sep 17 00:00:00 2001 From: Felix Kunde Date: Mon, 21 Feb 2022 17:27:10 +0100 Subject: [PATCH] sync publication with debug messages --- manifests/complete-postgres-manifest.yaml | 16 +++++++++------- pkg/cluster/database.go | 2 +- 2 files changed, 10 insertions(+), 8 deletions(-) diff --git a/manifests/complete-postgres-manifest.yaml b/manifests/complete-postgres-manifest.yaml index 74b3c7f85..514288e2e 100644 --- a/manifests/complete-postgres-manifest.yaml +++ b/manifests/complete-postgres-manifest.yaml @@ -205,13 +205,15 @@ spec: # - applicationId: test-app # database: foo # tables: -# data.tab_a: -# eventType: event_type_a -# data.tab_b: -# eventType: event_type_b -# idColumn: tb_id -# payloadColumn: tb_payload +# data.state_pending_outbox: +# eventType: test-app.status-pending +# data.state_approved_outbox: +# eventType: test-app.status-approved +# data.orders_outbox: +# eventType: test-app.order-completed +# idColumn: o_id +# payloadColumn: o_payload # # Optional. Filter ignores events before a certain txnId and lsn. Can be used to skip bad events # filter: -# data.tab_a: "[?(@.source.txId > 500 && @.source.lsn > 123456)]" +# data.orders_outbox: "[?(@.source.txId > 500 && @.source.lsn > 123456)]" # batchSize: 1000 diff --git a/pkg/cluster/database.go b/pkg/cluster/database.go index c30acd115..652f0d0ae 100644 --- a/pkg/cluster/database.go +++ b/pkg/cluster/database.go @@ -633,7 +633,7 @@ func (c *Cluster) executeAlterPublication(pubName, tableList string) error { func (c *Cluster) execCreateOrAlterPublication(pubName, tableList, statement, doing, operation string) error { - c.logger.Infof("%s %q with table list %q", doing, pubName, tableList) + c.logger.Debugf("%s %q with table list %q", doing, pubName, tableList) if _, err := c.pgDb.Exec(fmt.Sprintf(statement, pubName, tableList)); err != nil { return fmt.Errorf("could not execute %s: %v", operation, err) }