-
Feature Request
-
Resolution: Done
-
Minor
-
None
-
None
-
False
-
-
False
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);