diff --git a/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnectorTask.java b/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnectorTask.java index 029c7852e..138cc66e9 100644 --- a/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnectorTask.java +++ b/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerConnectorTask.java @@ -59,8 +59,8 @@ public ChangeEventSourceCoordinator // By default do not load whole result sets into memory config = config.edit() - .withDefault("database.responseBuffering", "adaptive") - .withDefault("database.fetchSize", 10_000) + .withDefault(CommonConnectorConfig.DRIVER_CONFIG_PREFIX + "responseBuffering", "adaptive") + .withDefault(CommonConnectorConfig.DRIVER_CONFIG_PREFIX + "fetchSize", 10_000) .build(); final SqlServerConnectorConfig connectorConfig = new SqlServerConnectorConfig(config);