From 9546b56254c65eedf9af63569d13857a6f3b5367 Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Mon, 6 Apr 2020 12:57:18 +0200 Subject: [PATCH] DBZ-1905 Validate database history topic --- .../main/java/io/debezium/connector/db2/Db2ConnectorConfig.java | 2 +- .../io/debezium/connector/oracle/OracleConnectorConfig.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java b/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java index 86797e7df..4c0dbc757 100644 --- a/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java +++ b/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java @@ -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()); diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java index fcb0c979d..20c057bae 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnectorConfig.java @@ -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);