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