[test] Move AssertUtils to flink-connector-debezium

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>

flink-connector-debezium/src/test/java/com/alibaba/ververica/cdc/debezium/utils/AssertUtils.java

@@ -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;

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.debezium.utils.AssertUtils.assertDelete;
-import static com.alibaba.ververica.cdc.connectors.mysql.utils.AssertUtils.assertInsert;
+import static com.alibaba.ververica.cdc.debezium.utils.AssertUtils.assertInsert;
-import static com.alibaba.ververica.cdc.connectors.mysql.utils.AssertUtils.assertUpdate;
+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;