DBZ-1905 Validate database history topic
This commit is contained in:
parent
084df1a2c0
commit
9546b56254
@ -286,7 +286,7 @@ public static ConfigDef configDef() {
|
||||
private final ColumnNameFilter columnFilter;
|
||||
|
||||
public Db2ConnectorConfig(Configuration config) {
|
||||
super(config, config.getString(SERVER_NAME), new SystemTablesPredicate(), x -> x.schema() + "." + x.table(), false);
|
||||
super(Db2Connector.class, config, config.getString(SERVER_NAME), new SystemTablesPredicate(), x -> x.schema() + "." + x.table(), false);
|
||||
|
||||
this.databaseName = config.getString(DATABASE_NAME);
|
||||
this.snapshotMode = SnapshotMode.parse(config.getString(SNAPSHOT_MODE), SNAPSHOT_MODE.defaultValueAsString());
|
||||
|
@ -125,7 +125,7 @@ public class OracleConnectorConfig extends HistorizedRelationalDatabaseConnector
|
||||
private final OracleVersion oracleVersion;
|
||||
|
||||
public OracleConnectorConfig(Configuration config) {
|
||||
super(config, config.getString(SERVER_NAME), new SystemTablesPredicate(), true);
|
||||
super(OracleConnector.class, config, config.getString(SERVER_NAME), new SystemTablesPredicate(), true);
|
||||
|
||||
this.databaseName = config.getString(DATABASE_NAME);
|
||||
this.pdbName = config.getString(PDB_NAME);
|
||||
|
Loading…
Reference in New Issue
Block a user