DBZ-7024 Switch abstract embedded tests to async engine
This commit is contained in:
parent
0137d5f15e
commit
4689db90c0
@ -22,7 +22,7 @@
|
|||||||
|
|
||||||
import io.debezium.config.Configuration;
|
import io.debezium.config.Configuration;
|
||||||
import io.debezium.doc.FixFor;
|
import io.debezium.doc.FixFor;
|
||||||
import io.debezium.embedded.AbstractConnectorTest;
|
import io.debezium.embedded.AbstractAsyncEngineConnectorTest;
|
||||||
import io.debezium.jdbc.JdbcConnection;
|
import io.debezium.jdbc.JdbcConnection;
|
||||||
import io.debezium.transforms.outbox.EventRouter;
|
import io.debezium.transforms.outbox.EventRouter;
|
||||||
|
|
||||||
@ -31,7 +31,7 @@
|
|||||||
*
|
*
|
||||||
* @author Roman Kudryashov
|
* @author Roman Kudryashov
|
||||||
*/
|
*/
|
||||||
public abstract class AbstractCloudEventsConverterTest<T extends SourceConnector> extends AbstractConnectorTest {
|
public abstract class AbstractCloudEventsConverterTest<T extends SourceConnector> extends AbstractAsyncEngineConnectorTest {
|
||||||
|
|
||||||
protected abstract Class<T> getConnectorClass();
|
protected abstract Class<T> getConnectorClass();
|
||||||
|
|
||||||
|
@ -46,12 +46,12 @@
|
|||||||
|
|
||||||
import io.debezium.config.CommonConnectorConfig;
|
import io.debezium.config.CommonConnectorConfig;
|
||||||
import io.debezium.config.Configuration;
|
import io.debezium.config.Configuration;
|
||||||
import io.debezium.embedded.AbstractConnectorTest;
|
import io.debezium.embedded.AbstractAsyncEngineConnectorTest;
|
||||||
import io.debezium.junit.logging.LogInterceptor;
|
import io.debezium.junit.logging.LogInterceptor;
|
||||||
import io.debezium.pipeline.notification.channels.SinkNotificationChannel;
|
import io.debezium.pipeline.notification.channels.SinkNotificationChannel;
|
||||||
import io.debezium.pipeline.notification.channels.jmx.JmxNotificationChannelMXBean;
|
import io.debezium.pipeline.notification.channels.jmx.JmxNotificationChannelMXBean;
|
||||||
|
|
||||||
public abstract class AbstractNotificationsIT<T extends SourceConnector> extends AbstractConnectorTest {
|
public abstract class AbstractNotificationsIT<T extends SourceConnector> extends AbstractAsyncEngineConnectorTest {
|
||||||
|
|
||||||
protected abstract Class<T> connectorClass();
|
protected abstract Class<T> connectorClass();
|
||||||
|
|
||||||
|
@ -24,13 +24,13 @@
|
|||||||
import org.apache.kafka.connect.source.SourceRecord;
|
import org.apache.kafka.connect.source.SourceRecord;
|
||||||
|
|
||||||
import io.debezium.config.Configuration;
|
import io.debezium.config.Configuration;
|
||||||
import io.debezium.embedded.AbstractConnectorTest;
|
import io.debezium.embedded.AbstractAsyncEngineConnectorTest;
|
||||||
import io.debezium.engine.DebeziumEngine;
|
import io.debezium.engine.DebeziumEngine;
|
||||||
import io.debezium.jdbc.JdbcConnection;
|
import io.debezium.jdbc.JdbcConnection;
|
||||||
import io.debezium.pipeline.signal.actions.AbstractSnapshotSignal;
|
import io.debezium.pipeline.signal.actions.AbstractSnapshotSignal;
|
||||||
import io.debezium.util.Strings;
|
import io.debezium.util.Strings;
|
||||||
|
|
||||||
public abstract class AbstractSnapshotTest<T extends SourceConnector> extends AbstractConnectorTest {
|
public abstract class AbstractSnapshotTest<T extends SourceConnector> extends AbstractAsyncEngineConnectorTest {
|
||||||
|
|
||||||
protected static final int ROW_COUNT = 1000;
|
protected static final int ROW_COUNT = 1000;
|
||||||
protected static final Path SCHEMA_HISTORY_PATH = Files.createTestingPath("file-schema-history-is.txt")
|
protected static final Path SCHEMA_HISTORY_PATH = Files.createTestingPath("file-schema-history-is.txt")
|
||||||
|
@ -20,7 +20,7 @@
|
|||||||
import io.debezium.data.Envelope;
|
import io.debezium.data.Envelope;
|
||||||
import io.debezium.data.VerifyRecord;
|
import io.debezium.data.VerifyRecord;
|
||||||
import io.debezium.doc.FixFor;
|
import io.debezium.doc.FixFor;
|
||||||
import io.debezium.embedded.AbstractConnectorTest;
|
import io.debezium.embedded.AbstractAsyncEngineConnectorTest;
|
||||||
import io.debezium.jdbc.JdbcConnection;
|
import io.debezium.jdbc.JdbcConnection;
|
||||||
import io.debezium.junit.logging.LogInterceptor;
|
import io.debezium.junit.logging.LogInterceptor;
|
||||||
import io.debezium.processors.reselect.ReselectColumnsPostProcessor;
|
import io.debezium.processors.reselect.ReselectColumnsPostProcessor;
|
||||||
@ -30,7 +30,7 @@
|
|||||||
/**
|
/**
|
||||||
* @author Chris Cranford
|
* @author Chris Cranford
|
||||||
*/
|
*/
|
||||||
public abstract class AbstractReselectProcessorTest<T extends SourceConnector> extends AbstractConnectorTest {
|
public abstract class AbstractReselectProcessorTest<T extends SourceConnector> extends AbstractAsyncEngineConnectorTest {
|
||||||
|
|
||||||
protected abstract Class<T> getConnectorClass();
|
protected abstract Class<T> getConnectorClass();
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user