diff --git a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlSourceTypeInSchemaIT.java b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlSourceTypeInSchemaIT.java index 1aaac7ec8..e32069741 100644 --- a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlSourceTypeInSchemaIT.java +++ b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlSourceTypeInSchemaIT.java @@ -66,7 +66,7 @@ public void shouldPropagateSourceTypeAsSchemaParameter() throws SQLException, In // Use the DB configuration to define the connector's configuration ... config = DATABASE.defaultConfig() .with(MySqlConnectorConfig.SNAPSHOT_MODE, MySqlConnectorConfig.SnapshotMode.NEVER) - .with("column.propagate.source.type", ".*c1,.*c2,.*c3.*,.*f.") + .with("column.propagate.source.type", ".*\\.c1,.*\\.c2,.*\\.c3.*,.*\\.f.") .build(); // Start the connector ...