diff --git a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/SnapshotParallelSourceIT.java b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/SnapshotParallelSourceIT.java index 0d93aeead..96ef0827e 100644 --- a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/SnapshotParallelSourceIT.java +++ b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/SnapshotParallelSourceIT.java @@ -21,6 +21,8 @@ import io.debezium.junit.logging.LogInterceptor; import io.debezium.util.Collect; +import ch.qos.logback.classic.Level; + @SkipWhenDatabaseVersion(check = LESS_THAN, major = 5, minor = 6, reason = "DDL uses fractional second data types, not supported until MySQL 5.6") public class SnapshotParallelSourceIT extends SnapshotSourceIT { @@ -74,6 +76,7 @@ public void shouldParallelCreateSnapshotSchema() throws Exception { .with(MySqlConnectorConfig.DATABASE_INCLUDE_LIST, String.join(",", includeDatabases)) .build(); LogInterceptor logInterceptor = new LogInterceptor(MySqlSnapshotChangeEventSource.class); + logInterceptor.setLoggerLevel(MySqlSnapshotChangeEventSource.class, Level.INFO); // Start the connector ... start(MySqlConnector.class, config);