Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-9247

Throw an exception on missing heartbeat table on Debezium-connector-postgres

XMLWordPrintable

      In case the heartbeat table hasn't been created, the connector could throw a DebeziumException so the users are notified there is something wrong.

      Discussed here (https://debezium.zulipchat.com/#narrow/channel/348249-community-postgresql/topic/Heartbeats.20.3A.20handle.20errors/near/529470401)

      Currently, the connector just logs the error.

      Implementation ideas :

      Catch the "42P01" SQL error code :

       

      case "42P01":
          // Postgres error undefined_table, see https://www.postgresql.org/docs/12/errcodes-appendix.html
          throw new DebeziumException("Could not execute heartbeat action query (Error: " + sqlErrorId + ")", exception);

       

              Unassigned Unassigned
              krakig Ifig Le Pennec (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: