DBZ-8375 Migrate rest of Debezium testsuite to async engine

aiven · Nov 6, 2024 · 16f6cdd · 16f6cdd
1 parent 43cdf50
commit 16f6cdd
Show file tree

Hide file tree

Showing 7 changed files with 14 additions and 14 deletions.
diff --git a/...onnector-postgres/src/test/java/io/debezium/connector/postgresql/SnapshotIsolationIT.java b/...onnector-postgres/src/test/java/io/debezium/connector/postgresql/SnapshotIsolationIT.java
@@ -24,12 +24,12 @@
 
 import io.debezium.config.Configuration;
 import io.debezium.data.SchemaAndValueField;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 
 /**
  * Integration test for {@link io.debezium.connector.postgresql.PostgresConnectorConfig.SNAPSHOT_ISOLATION_MODE}
  */
-public class SnapshotIsolationIT extends AbstractConnectorTest {
+public class SnapshotIsolationIT extends AbstractAsyncEngineConnectorTest {
 
     private static final String INSERT_STMT = "INSERT INTO s1.a (aa) VALUES (1);" +
             "INSERT INTO s2.a (aa) VALUES (2);" +

diff --git a/.../io/debezium/connector/postgresql/transforms/DecodeLogicalDecodingMessageContentTest.java b/.../io/debezium/connector/postgresql/transforms/DecodeLogicalDecodingMessageContentTest.java
@@ -37,15 +37,15 @@
 import io.debezium.connector.postgresql.junit.SkipWhenDecoderPluginNameIsNot;
 import io.debezium.data.Envelope;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.junit.SkipWhenDatabaseVersion;
 
 /**
  * Tests for {@link io.debezium.connector.postgresql.transforms.DecodeLogicalDecodingMessageContent} SMT.
  *
  * @author Roman Kudryashov
  */
-public class DecodeLogicalDecodingMessageContentTest extends AbstractConnectorTest {
+public class DecodeLogicalDecodingMessageContentTest extends AbstractAsyncEngineConnectorTest {
 
     @Rule
     public final TestRule skipName = new SkipTestDependingOnDecoderPluginNameRule();

diff --git a/debezium-embedded/src/test/java/io/debezium/pipeline/AbstractMetricsTest.java b/debezium-embedded/src/test/java/io/debezium/pipeline/AbstractMetricsTest.java
@@ -29,10 +29,10 @@
 import io.debezium.config.CommonConnectorConfig;
 import io.debezium.config.Configuration;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.util.Testing;
 
-public abstract class AbstractMetricsTest<T extends SourceConnector> extends AbstractConnectorTest {
+public abstract class AbstractMetricsTest<T extends SourceConnector> extends AbstractAsyncEngineConnectorTest {
 
     protected abstract Class<T> getConnectorClass();
 

diff --git a/...zium-embedded/src/test/java/io/debezium/relational/history/AbstractSchemaHistoryTest.java b/...zium-embedded/src/test/java/io/debezium/relational/history/AbstractSchemaHistoryTest.java
@@ -15,7 +15,7 @@
 
 import io.debezium.config.Configuration;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.pipeline.spi.OffsetContext;
 import io.debezium.pipeline.spi.Offsets;
 import io.debezium.pipeline.spi.Partition;
@@ -28,7 +28,7 @@
  *
  * @author Chris Cranford
  */
-public abstract class AbstractSchemaHistoryTest extends AbstractConnectorTest {
+public abstract class AbstractSchemaHistoryTest extends AbstractAsyncEngineConnectorTest {
 
     private MemorySchemaHistory schemaHistory;
 

diff --git a/debezium-embedded/src/test/java/io/debezium/transforms/outbox/AbstractEventRouterTest.java b/debezium-embedded/src/test/java/io/debezium/transforms/outbox/AbstractEventRouterTest.java
@@ -31,15 +31,15 @@
 
 import io.debezium.config.Configuration;
 import io.debezium.doc.FixFor;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.jdbc.JdbcConnection;
 
 /**
  * A unified test of all {@link EventRouter} behavior which all connectors should extend.
  *
  * @author Chris Cranford
  */
-public abstract class AbstractEventRouterTest<T extends SourceConnector> extends AbstractConnectorTest {
+public abstract class AbstractEventRouterTest<T extends SourceConnector> extends AbstractAsyncEngineConnectorTest {
 
     protected EventRouter<SourceRecord> outboxEventRouter;
 

diff --git a/...ebezium-storage-jdbc/src/test/java/io/debezium/storage/jdbc/JdbcOffsetBackingStoreIT.java b/...ebezium-storage-jdbc/src/test/java/io/debezium/storage/jdbc/JdbcOffsetBackingStoreIT.java
@@ -30,7 +30,7 @@
 import io.debezium.config.Configuration;
 import io.debezium.connector.mysql.MySqlConnector;
 import io.debezium.connector.mysql.MySqlConnectorConfig;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.jdbc.JdbcConfiguration;
 import io.debezium.jdbc.JdbcConnection;
 import io.debezium.junit.SkipWhenDatabaseVersion;
@@ -44,7 +44,7 @@
  * @author Kanthi Subramanian
  */
 @SkipWhenDatabaseVersion(check = LESS_THAN, major = 5, minor = 6, reason = "DDL uses fractional second data types, not supported until MySQL 5.6")
-public class JdbcOffsetBackingStoreIT extends AbstractConnectorTest {
+public class JdbcOffsetBackingStoreIT extends AbstractAsyncEngineConnectorTest {
     private static final Path SCHEMA_HISTORY_PATH = Testing.Files.createTestingPath("schema-history.db").toAbsolutePath();
 
     private static final String USER = "debezium";

diff --git a/...zium-storage-jdbc/src/test/java/io/debezium/storage/jdbc/history/JdbcSchemaHistoryIT.java b/...zium-storage-jdbc/src/test/java/io/debezium/storage/jdbc/history/JdbcSchemaHistoryIT.java
@@ -30,14 +30,14 @@
 import io.debezium.config.Configuration.Builder;
 import io.debezium.connector.mysql.MySqlConnector;
 import io.debezium.connector.mysql.MySqlConnectorConfig;
-import io.debezium.embedded.AbstractConnectorTest;
+import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.jdbc.JdbcConfiguration;
 import io.debezium.jdbc.JdbcConnection;
 import io.debezium.relational.history.SchemaHistory;
 import io.debezium.storage.jdbc.offset.JdbcOffsetBackingStoreConfig;
 import io.debezium.util.Testing;
 
-public class JdbcSchemaHistoryIT extends AbstractConnectorTest {
+public class JdbcSchemaHistoryIT extends AbstractAsyncEngineConnectorTest {
 
     private static final Path SCHEMA_HISTORY_PATH = Testing.Files.createTestingPath("schema-history.db").toAbsolutePath();