diff --git a/debezium-connector-mongodb/pom.xml b/debezium-connector-mongodb/pom.xml index 770f0110f..2c405c725 100644 --- a/debezium-connector-mongodb/pom.xml +++ b/debezium-connector-mongodb/pom.xml @@ -363,6 +363,19 @@ apicurio + + + + org.apache.maven.plugins + maven-failsafe-plugin + + + true + + + + + ${docker.dbs},apicurio/apicurio-registry-mem:${version.apicurio} diff --git a/debezium-connector-mysql/pom.xml b/debezium-connector-mysql/pom.xml index 94df87881..19c3bf69c 100644 --- a/debezium-connector-mysql/pom.xml +++ b/debezium-connector-mysql/pom.xml @@ -852,6 +852,19 @@ apicurio + + + + org.apache.maven.plugins + maven-failsafe-plugin + + + true + + + + + ${docker.dbs},apicurio/apicurio-registry-mem:${version.apicurio} diff --git a/debezium-connector-oracle/pom.xml b/debezium-connector-oracle/pom.xml index 6e7005771..34218f7c8 100644 --- a/debezium-connector-oracle/pom.xml +++ b/debezium-connector-oracle/pom.xml @@ -580,6 +580,19 @@ apicurio + + + + org.apache.maven.plugins + maven-failsafe-plugin + + + true + + + + + ${docker.dbs},apicurio/apicurio-registry-mem:${version.apicurio} diff --git a/debezium-connector-postgres/pom.xml b/debezium-connector-postgres/pom.xml index f661fa433..f98e14c7a 100644 --- a/debezium-connector-postgres/pom.xml +++ b/debezium-connector-postgres/pom.xml @@ -443,6 +443,19 @@ apicurio + + + + org.apache.maven.plugins + maven-failsafe-plugin + + + true + + + + + ${docker.dbs},apicurio/apicurio-registry-mem:${version.apicurio} diff --git a/debezium-connector-sqlserver/pom.xml b/debezium-connector-sqlserver/pom.xml index aa459c19b..6fe55d666 100644 --- a/debezium-connector-sqlserver/pom.xml +++ b/debezium-connector-sqlserver/pom.xml @@ -346,6 +346,19 @@ apicurio + + + + org.apache.maven.plugins + maven-failsafe-plugin + + + true + + + + + ${docker.dbs},apicurio/apicurio-registry-mem:${version.apicurio} diff --git a/debezium-core/src/test/java/io/debezium/data/VerifyRecord.java b/debezium-core/src/test/java/io/debezium/data/VerifyRecord.java index 5e2712b08..866bfda3a 100644 --- a/debezium-core/src/test/java/io/debezium/data/VerifyRecord.java +++ b/debezium-core/src/test/java/io/debezium/data/VerifyRecord.java @@ -8,10 +8,7 @@ import static org.assertj.core.api.Assertions.assertThat; import static org.junit.Assert.fail; -import java.io.IOException; import java.math.BigDecimal; -import java.net.HttpURLConnection; -import java.net.URL; import java.nio.ByteBuffer; import java.time.LocalDateTime; import java.time.ZoneId; @@ -1288,15 +1285,8 @@ private static Object setVersion(Object obj, Integer version) { } public static boolean isApucurioAvailable() { - try { - HttpURLConnection conn = (HttpURLConnection) new URL(APICURIO_URL).openConnection(); - conn.setRequestMethod("HEAD"); - int respCode = conn.getResponseCode(); - return respCode == 200; - } - catch (IOException e) { - return false; - } + String useApicurio = System.getProperty("use.apicurio"); + return useApicurio != null && useApicurio.equalsIgnoreCase("true"); } }