diff --git a/debezium-core/src/main/java/io/debezium/relational/HistorizedRelationalDatabaseConnectorConfig.java b/debezium-core/src/main/java/io/debezium/relational/HistorizedRelationalDatabaseConnectorConfig.java index a97ecb837..4b0438096 100644 --- a/debezium-core/src/main/java/io/debezium/relational/HistorizedRelationalDatabaseConnectorConfig.java +++ b/debezium-core/src/main/java/io/debezium/relational/HistorizedRelationalDatabaseConnectorConfig.java @@ -34,6 +34,7 @@ public abstract class HistorizedRelationalDatabaseConnectorConfig extends Relati protected static final int DEFAULT_SNAPSHOT_FETCH_SIZE = 2_000; private static final String DEFAULT_SCHEMA_HISTORY = "io.debezium.storage.kafka.history.KafkaSchemaHistory"; + private final boolean useCatalogBeforeSchema; private final Class connectorClass; private final boolean multiPartitionMode;