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

DBZ-1440 Temporary replication slots on PG10+ only

Browse Source
This commit is contained in:
Cyril Scetbon 2019-08-19 12:35:34 -04:00 committed by Chris Cranford
parent 4b5475391c
commit 135e66dd0d
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -202,17 +202,11 @@ else if (shouldCreateSlot || !slotInfo.hasValidFlushedLsn()) {
}
}
// Temporary replication slots is a new feature of PostgreSQL 10
private boolean useTemporarySlot() throws SQLException {
return dropSlotOnClose && isPg94OrGreater();
return dropSlotOnClose && pgConnection().haveMinimumServerVersion(100000);
}
private boolean exportSnapshotOnCreate() throws SQLException {
return exportSnapshot && isPg94OrGreater();
}
private boolean isPg94OrGreater() throws SQLException {
return pgConnection().haveMinimumServerVersion(90400);
}
/**
* creating a replication connection and starting to stream involves a few steps:
* 1. we create the connection and ensure that
@ -276,7 +270,8 @@ public Optional<SlotCreationResult> createReplicationSlot() throws SQLException
LOGGER.debug("Creating new replication slot '{}' for plugin '{}'", slotName, plugin);
String tempPart = "";
Boolean canExportSnapshot = isPg94OrGreater();
// Exported snapshots are supported in PostgreSQL 9.4+
Boolean canExportSnapshot = pgConnection().haveMinimumServerVersion(90400);
if ((dropSlotOnClose || exportSnapshot) && !canExportSnapshot) {
LOGGER.warn("A slot marked as temporary or with an exported snapshot was created, " +
"but not on a supported version of Postgres, ignoring!");