diff --git a/flink-connector-debezium/pom.xml b/flink-connector-debezium/pom.xml
index 2689a272b..3917d2fce 100644
--- a/flink-connector-debezium/pom.xml
+++ b/flink-connector-debezium/pom.xml
@@ -48,6 +48,13 @@ under the License.
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-test-utils_${scala.binary.version}</artifactId>
+            <version>${flink.version}</version>
+            <scope>test</scope>
+        </dependency>
+
     </dependencies>
 
     <build>
diff --git a/flink-connector-mysql-cdc/src/test/java/com/alibaba/ververica/cdc/connectors/mysql/utils/AssertUtils.java b/flink-connector-debezium/src/test/java/com/alibaba/ververica/cdc/debezium/utils/AssertUtils.java
similarity index 96%
rename from flink-connector-mysql-cdc/src/test/java/com/alibaba/ververica/cdc/connectors/mysql/utils/AssertUtils.java
rename to flink-connector-debezium/src/test/java/com/alibaba/ververica/cdc/debezium/utils/AssertUtils.java
index cd0047829..519997104 100644
--- a/flink-connector-mysql-cdc/src/test/java/com/alibaba/ververica/cdc/connectors/mysql/utils/AssertUtils.java
+++ b/flink-connector-debezium/src/test/java/com/alibaba/ververica/cdc/debezium/utils/AssertUtils.java
@@ -1,13 +1,13 @@
 /*
  * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
+ * or more contributor license agreements.See the NOTICE file
  * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
+ * regarding copyright ownership.The ASF licenses this file
  * to you under the Apache License, Version 2.0 (the
  * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
+ * with the License.You may obtain a copy of the License at
  *
- *     http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package com.alibaba.ververica.cdc.connectors.mysql.utils;
+package com.alibaba.ververica.cdc.debezium.utils;
 
 import io.debezium.data.Envelope;
 import org.apache.kafka.connect.data.Struct;
diff --git a/flink-connector-mysql-cdc/src/test/java/com/alibaba/ververica/cdc/connectors/mysql/MySqlBinlogSourceTest.java b/flink-connector-mysql-cdc/src/test/java/com/alibaba/ververica/cdc/connectors/mysql/MySqlBinlogSourceTest.java
index e42b88c88..ff6958e35 100644
--- a/flink-connector-mysql-cdc/src/test/java/com/alibaba/ververica/cdc/connectors/mysql/MySqlBinlogSourceTest.java
+++ b/flink-connector-mysql-cdc/src/test/java/com/alibaba/ververica/cdc/connectors/mysql/MySqlBinlogSourceTest.java
@@ -56,9 +56,9 @@ import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.Semaphore;
 import java.util.concurrent.TimeUnit;
 
-import static com.alibaba.ververica.cdc.connectors.mysql.utils.AssertUtils.assertDelete;
-import static com.alibaba.ververica.cdc.connectors.mysql.utils.AssertUtils.assertInsert;
-import static com.alibaba.ververica.cdc.connectors.mysql.utils.AssertUtils.assertUpdate;
+import static com.alibaba.ververica.cdc.debezium.utils.AssertUtils.assertDelete;
+import static com.alibaba.ververica.cdc.debezium.utils.AssertUtils.assertInsert;
+import static com.alibaba.ververica.cdc.debezium.utils.AssertUtils.assertUpdate;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;