alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5739 Handle permission error from RDS Postgres

Browse Source
This commit is contained in:
Praveen Burgu 2022-11-29 11:21:21 -08:00 committed by Jiri Pechanec
parent 1ba3ac1949
commit ad6ec2be6a
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java
View File

@ -368,6 +368,9 @@ protected void validateSlotIsInExpectedState(WalPositionLocator walPosition) thr
if (e.getMessage().matches("ERROR: function pg_replication_slot_advance.*does not exist(.|\\n)*")) {
LOGGER.info("Postgres server doesn't support the command pg_replication_slot_advance(). Not seeking to last known offset.");
}
else if (e.getMessage().matches("ERROR: must be superuser or replication role to use replication slots(.|\\n)*")) {
LOGGER.warn("Unable to use pg_replication_slot_advance() function. The Postgres server is likely on an old RDS version: " + e.getMessage());
}
else if (e.getMessage().matches("ERROR: cannot advance replication slot to.*")) {
throw new DebeziumException(
String.format("Cannot seek to the last known offset '%s' on replication slot '%s'. Error from server: %s", lsn.asString(), slotName,