public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

sync publication with debug messages

This commit is contained in:
Felix Kunde 2022-02-21 17:27:10 +01:00
parent 34cad4601d
commit 795cd5d4ec
2 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
manifests/complete-postgres-manifest.yaml
View File

@ -205,13 +205,15 @@ spec:
# - applicationId: test-app # - applicationId: test-app
# database: foo # database: foo
# tables: # tables:
# data.tab_a: # data.state_pending_outbox:
# eventType: event_type_a # eventType: test-app.status-pending
# data.tab_b: # data.state_approved_outbox:
# eventType: event_type_b # eventType: test-app.status-approved
# idColumn: tb_id # data.orders_outbox:
# payloadColumn: tb_payload # 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 # # Optional. Filter ignores events before a certain txnId and lsn. Can be used to skip bad events
# filter: # filter:
# data.tab_a: "[?(@.source.txId > 500 && @.source.lsn > 123456)]" # data.orders_outbox: "[?(@.source.txId > 500 && @.source.lsn > 123456)]"
# batchSize: 1000 # batchSize: 1000

2
pkg/cluster/database.go
View File

@ -633,7 +633,7 @@ func (c *Cluster) executeAlterPublication(pubName, tableList string) error {
func (c *Cluster) execCreateOrAlterPublication(pubName, tableList, statement, doing, operation 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 { if _, err := c.pgDb.Exec(fmt.Sprintf(statement, pubName, tableList)); err != nil {
return fmt.Errorf("could not execute %s: %v", operation, err) return fmt.Errorf("could not execute %s: %v", operation, err)
} }