From b7ddf8d33af664f5a9fcae1e5053b27c2715537b Mon Sep 17 00:00:00 2001
From: Chris Cranford <chris@hibernate.org>
Date: Thu, 18 Aug 2022 11:38:55 -0400
Subject: [PATCH] DBZ-5526 Ignore all but verifyOffsets

---
 .../sqlserver/CaseSensitivenessIT.java        |  2 +
 .../sqlserver/DatatypesFromSnapshotIT.java    |  2 +
 .../EventProcessingFailureHandlingIT.java     |  2 +
 .../connector/sqlserver/FieldTest.java        |  2 +
 .../sqlserver/IncrementalSnapshotIT.java      |  2 +
 .../IncrementalSnapshotWithRecompileIT.java   |  2 +
 .../sqlserver/SQLServerNumericColumnIT.java   |  2 +
 .../sqlserver/SchemaHistoryTopicIT.java       |  2 +
 .../connector/sqlserver/SnapshotIT.java       |  2 +
 .../SnapshotWithSelectOverridesIT.java        |  2 +
 .../connector/sqlserver/SourceInfoTest.java   |  2 +
 .../sqlserver/SpecialCharsInNamesIT.java      |  2 +
 .../sqlserver/SqlServerBinaryModeIT.java      |  2 +
 .../sqlserver/SqlServerChangeTableSetIT.java  |  2 +
 .../sqlserver/SqlServerConnectionIT.java      |  2 +
 .../SqlServerConnectorConfigDefTest.java      |  3 ++
 .../SqlServerConnectorConfigTest.java         |  2 +
 .../sqlserver/SqlServerConnectorIT.java       | 51 +++++++++++++++++++
 ...qlServerConnectorMultiPartitionModeIT.java |  2 +
 .../sqlserver/SqlServerConnectorTest.java     |  2 +
 .../sqlserver/SqlServerPartitionTest.java     |  3 ++
 .../SqlServerSchemaNameAdjustmentModeIT.java  |  2 +
 .../TablesWithUniqueIndexOnlyIT.java          |  2 +
 .../sqlserver/TablesWithoutPrimaryKeyIT.java  |  2 +
 .../sqlserver/TransactionMetadataIT.java      |  2 +
 25 files changed, 101 insertions(+)

diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/CaseSensitivenessIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/CaseSensitivenessIT.java
index f8830d85c2c..80a39065d4a 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/CaseSensitivenessIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/CaseSensitivenessIT.java
@@ -14,6 +14,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -28,6 +29,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 public class CaseSensitivenessIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/DatatypesFromSnapshotIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/DatatypesFromSnapshotIT.java
index 342f1ac96bb..295f1c3067e 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/DatatypesFromSnapshotIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/DatatypesFromSnapshotIT.java
@@ -9,6 +9,7 @@
 
 import org.junit.Before;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 
 import io.debezium.jdbc.TemporalPrecisionMode;
 
@@ -18,6 +19,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 public class DatatypesFromSnapshotIT extends AbstractSqlServerDatatypesTest {
 
     @BeforeClass
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/EventProcessingFailureHandlingIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/EventProcessingFailureHandlingIT.java
index b67d67070b9..ccc069ef2ac 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/EventProcessingFailureHandlingIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/EventProcessingFailureHandlingIT.java
@@ -12,6 +12,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.CommonConnectorConfig.EventProcessingFailureHandlingMode;
@@ -31,6 +32,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 public class EventProcessingFailureHandlingIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/FieldTest.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/FieldTest.java
index b5a5531e03b..6f4c926156f 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/FieldTest.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/FieldTest.java
@@ -7,9 +7,11 @@
 package io.debezium.connector.sqlserver;
 
 import org.junit.Before;
+import org.junit.Ignore;
 
 import io.debezium.config.AbstractFieldTest;
 
+@Ignore
 public class FieldTest extends AbstractFieldTest {
 
     @Before
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotIT.java
index 36ed690a93c..9fe0c81d573 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotIT.java
@@ -11,6 +11,7 @@
 
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Rule;
 
 import io.debezium.config.Configuration.Builder;
@@ -22,6 +23,7 @@
 import io.debezium.relational.history.DatabaseHistory;
 import io.debezium.util.Testing;
 
+@Ignore
 public class IncrementalSnapshotIT extends AbstractIncrementalSnapshotWithSchemaChangesSupportTest<SqlServerConnector> {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java
index f500610dc23..65d82121936 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/IncrementalSnapshotWithRecompileIT.java
@@ -10,6 +10,7 @@
 
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Rule;
 
 import io.debezium.config.Configuration.Builder;
@@ -21,6 +22,7 @@
 import io.debezium.relational.history.DatabaseHistory;
 import io.debezium.util.Testing;
 
+@Ignore
 public class IncrementalSnapshotWithRecompileIT extends AbstractIncrementalSnapshotTest<SqlServerConnector> {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SQLServerNumericColumnIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SQLServerNumericColumnIT.java
index 1bbb5ae867c..d3ccaae4793 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SQLServerNumericColumnIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SQLServerNumericColumnIT.java
@@ -16,6 +16,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -31,6 +32,7 @@
  * @author Pradeep Mamillapalli
  *
  */
+@Ignore
 public class SQLServerNumericColumnIT extends AbstractConnectorTest {
     private SqlServerConnection connection;
 
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SchemaHistoryTopicIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SchemaHistoryTopicIT.java
index 4e1eebeaf54..227e6b9402f 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SchemaHistoryTopicIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SchemaHistoryTopicIT.java
@@ -18,6 +18,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -37,6 +38,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 public class SchemaHistoryTopicIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java
index 8ba232e1f76..fb86915ccb9 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java
@@ -25,6 +25,7 @@
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.CommonConnectorConfig;
@@ -50,6 +51,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 public class SnapshotIT extends AbstractConnectorTest {
 
     private static final int INITIAL_RECORDS_PER_TABLE = 500;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotWithSelectOverridesIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotWithSelectOverridesIT.java
index ba3a0a07717..424a4edd59a 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotWithSelectOverridesIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotWithSelectOverridesIT.java
@@ -15,6 +15,7 @@
 import org.apache.kafka.connect.source.SourceRecord;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -29,6 +30,7 @@
  *
  * @author Gunnar Morling
  */
+@Ignore
 public class SnapshotWithSelectOverridesIT extends AbstractConnectorTest {
 
     private static final int INITIAL_RECORDS_PER_TABLE = 10;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SourceInfoTest.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SourceInfoTest.java
index 6d0a1f216b4..20024d02ebf 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SourceInfoTest.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SourceInfoTest.java
@@ -12,6 +12,7 @@
 import org.apache.kafka.connect.data.Schema;
 import org.apache.kafka.connect.data.SchemaBuilder;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -19,6 +20,7 @@
 import io.debezium.connector.SnapshotRecord;
 import io.debezium.relational.TableId;
 
+@Ignore
 public class SourceInfoTest {
 
     private SourceInfo source;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SpecialCharsInNamesIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SpecialCharsInNamesIT.java
index 8df1c4307ea..44d4f714696 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SpecialCharsInNamesIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SpecialCharsInNamesIT.java
@@ -15,6 +15,7 @@
 import org.apache.kafka.connect.data.Struct;
 import org.apache.kafka.connect.source.SourceRecord;
 import org.junit.After;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -29,6 +30,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 public class SpecialCharsInNamesIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerBinaryModeIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerBinaryModeIT.java
index 7c9b7df7eb9..4542e6ab85e 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerBinaryModeIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerBinaryModeIT.java
@@ -16,6 +16,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.CommonConnectorConfig.BinaryHandlingMode;
@@ -24,6 +25,7 @@
 import io.debezium.embedded.AbstractConnectorTest;
 import io.debezium.util.Testing;
 
+@Ignore
 public class SqlServerBinaryModeIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerChangeTableSetIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerChangeTableSetIT.java
index d95b915a358..9bcf12fe723 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerChangeTableSetIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerChangeTableSetIT.java
@@ -19,6 +19,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -38,6 +39,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 public class SqlServerChangeTableSetIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectionIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectionIT.java
index 761dbf5ca4a..69c98aa1738 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectionIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectionIT.java
@@ -23,6 +23,7 @@
 import org.awaitility.Awaitility;
 import org.fest.assertions.Assertions;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.connector.sqlserver.util.TestHelper;
@@ -44,6 +45,7 @@
  *
  * @author Horia Chiorean (hchiorea@redhat.com)
  */
+@Ignore
 public class SqlServerConnectionIT {
 
     private ZoneOffset databaseZoneOffset;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigDefTest.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigDefTest.java
index 9f630fa9dd6..047ed910de0 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigDefTest.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigDefTest.java
@@ -5,8 +5,11 @@
  */
 package io.debezium.connector.sqlserver;
 
+import org.junit.Ignore;
+
 import io.debezium.config.ConfigDefinitionMetadataTest;
 
+@Ignore
 public class SqlServerConnectorConfigDefTest extends ConfigDefinitionMetadataTest {
 
     public SqlServerConnectorConfigDefTest() {
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigTest.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigTest.java
index 64f22d3bdf0..beaf52e615f 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigTest.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorConfigTest.java
@@ -8,6 +8,7 @@
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 
+import org.junit.Ignore;
 import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -15,6 +16,7 @@
 import io.debezium.config.Configuration;
 import io.debezium.storage.kafka.history.KafkaDatabaseHistory;
 
+@Ignore
 public class SqlServerConnectorConfigTest {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(SqlServerConnectorConfigTest.class);
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java
index 815f65bc4eb..9907d62b384 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorIT.java
@@ -103,6 +103,7 @@ public void after() throws SQLException {
     }
 
     @Test
+    @Ignore
     public void createAndDelete() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -180,6 +181,7 @@ public void createAndDelete() throws Exception {
 
     @Test
     @FixFor("DBZ-1642")
+    @Ignore
     public void readOnlyApplicationIntent() throws Exception {
         final LogInterceptor logInterceptor = new LogInterceptor(SqlServerSnapshotChangeEventSource.class);
         final String appId = "readOnlyApplicationIntent-" + UUID.randomUUID();
@@ -260,6 +262,7 @@ public void readOnlyApplicationIntent() throws Exception {
 
     @Test
     @FixFor("DBZ-1643")
+    @Ignore
     public void timestampAndTimezone() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -308,6 +311,7 @@ public void timestampAndTimezone() throws Exception {
     }
 
     @Test
+    @Ignore
     public void deleteWithoutTombstone() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -356,6 +360,7 @@ public void deleteWithoutTombstone() throws Exception {
     }
 
     @Test
+    @Ignore
     public void update() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int ID_START = 10;
@@ -415,6 +420,7 @@ public void update() throws Exception {
     }
 
     @Test
+    @Ignore
     public void updatePrimaryKey() throws Exception {
 
         final Configuration config = TestHelper.defaultConfig()
@@ -514,6 +520,7 @@ public void updatePrimaryKey() throws Exception {
 
     @Test
     @FixFor("DBZ-1152")
+    @Ignore
     public void updatePrimaryKeyWithRestartInMiddle() throws Exception {
 
         final Configuration config = TestHelper.defaultConfig()
@@ -621,6 +628,7 @@ public void updatePrimaryKeyWithRestartInMiddle() throws Exception {
 
     @Test
     @FixFor("DBZ-2329")
+    @Ignore
     public void updatePrimaryKeyTwiceWithRestartInMiddleOfTx() throws Exception {
 
         final Configuration config = TestHelper.defaultConfig()
@@ -670,6 +678,7 @@ public void updatePrimaryKeyTwiceWithRestartInMiddleOfTx() throws Exception {
     }
 
     @Test
+    @Ignore
     public void streamChangesWhileStopped() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -867,6 +876,7 @@ public void verifyOffsets() throws Exception {
     }
 
     @Test
+    @Ignore
     public void testIncludeTable() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 1;
@@ -903,6 +913,7 @@ public void testIncludeTable() throws Exception {
 
     @Test
     @FixFor("DBZ-4346")
+    @Ignore
     public void shouldReportConfigurationErrorForUserNotHavingAccessToCDCTableInInitialMode() throws Exception {
         // First create a new user with only db_datareader role
         String testUserCreateSql = "IF EXISTS (select 1 from sys.server_principals where name = 'test_user')\n"
@@ -927,6 +938,7 @@ public void shouldReportConfigurationErrorForUserNotHavingAccessToCDCTableInInit
 
     @Test
     @FixFor("DBZ-4346")
+    @Ignore
     public void shouldNotReportConfigurationErrorForUserNotHavingAccessToCDCTableInInitialOnlyMode() throws Exception {
         // First create a new user with only db_datareader role
         String testUserCreateSql = "IF EXISTS (select 1 from sys.server_principals where name = 'test_user')\n"
@@ -950,6 +962,7 @@ public void shouldNotReportConfigurationErrorForUserNotHavingAccessToCDCTableInI
     }
 
     @Test
+    @Ignore
     public void testTableIncludeList() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 1;
@@ -986,6 +999,7 @@ public void testTableIncludeList() throws Exception {
     }
 
     @Test
+    @Ignore
     public void testTableExcludeList() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 1;
@@ -1022,6 +1036,7 @@ public void testTableExcludeList() throws Exception {
 
     @Test
     @FixFor("DBZ-1617")
+    @Ignore
     public void blacklistColumnWhenCdcColumnsDoNotMatchWithOriginalSnapshot() throws Exception {
         connection.execute("CREATE TABLE table_a (id int, name varchar(30), amount integer primary key(id))");
         TestHelper.enableTableCdc(connection, "table_a");
@@ -1066,6 +1081,7 @@ public void blacklistColumnWhenCdcColumnsDoNotMatchWithOriginalSnapshot() throws
 
     @Test
     @FixFor("DBZ-1067")
+    @Ignore
     public void testColumnExcludeList() throws Exception {
         connection.execute(
                 "CREATE TABLE blacklist_column_table_a (id int, name varchar(30), amount integer primary key(id))",
@@ -1128,6 +1144,7 @@ public void testColumnExcludeList() throws Exception {
 
     @Test
     @FixFor("DBZ-2522")
+    @Ignore
     public void testColumnIncludeList() throws Exception {
         connection.execute(
                 "CREATE TABLE include_list_column_table_a (id int, name varchar(30), amount integer primary key(id))",
@@ -1191,6 +1208,7 @@ public void testColumnIncludeList() throws Exception {
 
     @Test
     @FixFor("DBZ-3505")
+    @Ignore
     public void shouldHandleInvalidColumnFilter() throws Exception {
         final Configuration config = TestHelper.defaultConfig()
                 .with(SqlServerConnectorConfig.COLUMN_INCLUDE_LIST, ".^")
@@ -1212,6 +1230,7 @@ public void shouldHandleInvalidColumnFilter() throws Exception {
 
     @Test
     @FixFor("DBZ-1692")
+    @Ignore
     public void shouldConsumeEventsWithMaskedHashedColumns() throws Exception {
         connection.execute(
                 "CREATE TABLE masked_hashed_column_table_a (id int, name varchar(255) primary key(id))",
@@ -1260,6 +1279,7 @@ record = tableB.get(0);
 
     @Test
     @FixFor("DBZ-1972")
+    @Ignore
     public void shouldConsumeEventsWithMaskedAndTruncatedColumns() throws Exception {
         connection.execute(
                 "CREATE TABLE masked_hashed_column_table (id int, name varchar(255) primary key(id))",
@@ -1309,6 +1329,7 @@ record = tableB.get(0);
 
     @Test
     @FixFor("DBZ-2522")
+    @Ignore
     public void whenCaptureInstanceExcludesColumnsExpectSnapshotAndStreamingToExcludeColumns() throws Exception {
         connection.execute(
                 "CREATE TABLE excluded_column_table_a (id int, name varchar(30), amount integer primary key(id))");
@@ -1355,6 +1376,7 @@ public void whenCaptureInstanceExcludesColumnsExpectSnapshotAndStreamingToExclud
 
     @Test
     @FixFor("DBZ-2522")
+    @Ignore
     public void whenMultipleCaptureInstancesExcludesColumnsExpectLatestCDCTableUtilized() throws Exception {
         connection.execute(
                 "CREATE TABLE excluded_column_table_a (id int, name varchar(30), amount integer primary key(id))");
@@ -1469,6 +1491,7 @@ public void whenCaptureInstanceExcludesColumnsAndColumnsRenamedExpectNoErrors()
 
     @Test
     @FixFor("DBZ-1068")
+    @Ignore
     public void excludeColumnWhenCaptureInstanceExcludesColumns() throws Exception {
         connection.execute(
                 "CREATE TABLE excluded_column_table_a (id int, name varchar(30), amount integer primary key(id))");
@@ -1508,6 +1531,7 @@ public void excludeColumnWhenCaptureInstanceExcludesColumns() throws Exception {
 
     @Test
     @FixFor("DBZ-2522")
+    @Ignore
     public void excludeColumnWhenCaptureInstanceExcludesColumnInMiddleOfTable() throws Exception {
         connection.execute(
                 "CREATE TABLE exclude_list_column_table_a (id int, amount integer, name varchar(30), primary key(id))");
@@ -1556,6 +1580,7 @@ public void excludeColumnWhenCaptureInstanceExcludesColumnInMiddleOfTable() thro
 
     @Test
     @FixFor("DBZ-2522")
+    @Ignore
     public void includeColumnsWhenCaptureInstanceExcludesColumnInMiddleOfTable() throws Exception {
         connection.execute(
                 "CREATE TABLE include_list_column_table_a (id int, amount integer, name varchar(30), primary key(id))");
@@ -1597,6 +1622,7 @@ public void includeColumnsWhenCaptureInstanceExcludesColumnInMiddleOfTable() thr
 
     @Test
     @FixFor("DBZ-2522")
+    @Ignore
     public void excludeMultipleColumnsWhenCaptureInstanceExcludesSingleColumn() throws Exception {
         connection.execute(
                 "CREATE TABLE exclude_list_column_table_a (id int, amount integer, note varchar(30), name varchar(30), primary key(id))");
@@ -1639,6 +1665,7 @@ public void excludeMultipleColumnsWhenCaptureInstanceExcludesSingleColumn() thro
 
     @Test
     @FixFor("DBZ-2522")
+    @Ignore
     public void includeMultipleColumnsWhenCaptureInstanceExcludesSingleColumn() throws Exception {
         connection.execute(
                 "CREATE TABLE include_list_column_table_a (id int, amount integer, note varchar(30), name varchar(30), primary key(id))");
@@ -1684,6 +1711,7 @@ public void includeMultipleColumnsWhenCaptureInstanceExcludesSingleColumn() thro
      */
     @Test
     @FixFor("DBZ-964")
+    @Ignore
     public void shouldPropagateDatabaseDriverProperties() throws Exception {
         final Configuration config = TestHelper.defaultConfig()
                 .with(SqlServerConnectorConfig.SNAPSHOT_MODE, SnapshotMode.SCHEMA_ONLY)
@@ -1843,24 +1871,28 @@ private void restartInTheMiddleOfTx(boolean restartJustAfterSnapshot, boolean af
 
     @Test
     @FixFor("DBZ-1128")
+    @Ignore
     public void restartInTheMiddleOfTxAfterSnapshot() throws Exception {
         restartInTheMiddleOfTx(true, false);
     }
 
     @Test
     @FixFor("DBZ-1128")
+    @Ignore
     public void restartInTheMiddleOfTxAfterCompletedTx() throws Exception {
         restartInTheMiddleOfTx(false, true);
     }
 
     @Test
     @FixFor("DBZ-1128")
+    @Ignore
     public void restartInTheMiddleOfTx() throws Exception {
         restartInTheMiddleOfTx(false, false);
     }
 
     @Test
     @FixFor("DBZ-1242")
+    @Ignore
     public void testEmptySchemaWarningAfterApplyingFilters() throws Exception {
         // This captures all logged messages, allowing us to verify log message was written.
         final LogInterceptor logInterceptor = new LogInterceptor(RelationalDatabaseSchema.class);
@@ -1879,6 +1911,7 @@ public void testEmptySchemaWarningAfterApplyingFilters() throws Exception {
 
     @Test
     @FixFor("DBZ-1242")
+    @Ignore
     public void testNoEmptySchemaWarningAfterApplyingFilters() throws Exception {
         // This captures all logged messages, allowing us to verify log message was written.
         final LogInterceptor logInterceptor = new LogInterceptor(RelationalDatabaseSchema.class);
@@ -1896,6 +1929,7 @@ public void testNoEmptySchemaWarningAfterApplyingFilters() throws Exception {
 
     @Test
     @FixFor("DBZ-916")
+    @Ignore
     public void keylessTable() throws Exception {
         connection.execute(
                 "CREATE TABLE keyless (id int, name varchar(30))",
@@ -1953,6 +1987,7 @@ public void keylessTable() throws Exception {
 
     @Test
     @FixFor("DBZ-1015")
+    @Ignore
     public void shouldRewriteIdentityKey() throws InterruptedException, SQLException {
 
         connection.execute(
@@ -1980,6 +2015,7 @@ public void shouldRewriteIdentityKey() throws InterruptedException, SQLException
 
     @Test
     @FixFor("DBZ-1491")
+    @Ignore
     public void shouldCaptureTableSchema() throws SQLException, InterruptedException {
         connection.execute(
                 "CREATE TABLE table_schema_test (key_cola int not null,"
@@ -2028,6 +2064,7 @@ public void shouldCaptureTableSchema() throws SQLException, InterruptedException
 
     @Test
     @FixFor("DBZ-1923")
+    @Ignore
     public void shouldDetectPurgedHistory() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -2084,6 +2121,7 @@ public void shouldDetectPurgedHistory() throws Exception {
 
     @Test
     @FixFor("DBZ-1312")
+    @Ignore
     public void useShortTableNamesForColumnMapper() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -2132,6 +2170,7 @@ public void useShortTableNamesForColumnMapper() throws Exception {
 
     @Test
     @FixFor("DBZ-1312")
+    @Ignore
     public void useLongTableNamesForColumnMapper() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -2180,6 +2219,7 @@ public void useLongTableNamesForColumnMapper() throws Exception {
 
     @Test
     @FixFor("DBZ-1312")
+    @Ignore
     public void useLongTableNamesForKeyMapper() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -2228,6 +2268,7 @@ public void useLongTableNamesForKeyMapper() throws Exception {
 
     @Test
     @FixFor("DBZ-1312")
+    @Ignore
     public void useShortTableNamesForKeyMapper() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -2276,6 +2317,7 @@ public void useShortTableNamesForKeyMapper() throws Exception {
 
     @Test
     @FixFor({ "DBZ-1916", "DBZ-1830" })
+    @Ignore
     public void shouldPropagateSourceTypeByDatatype() throws Exception {
         connection.execute("CREATE TABLE dt_table (id int, c1 int, c2 int, c3a numeric(5,2), c3b varchar(128), f1 float(10), f2 decimal(8,4) primary key(id))");
         TestHelper.enableTableCdc(connection, "dt_table");
@@ -2324,6 +2366,7 @@ public void shouldPropagateSourceTypeByDatatype() throws Exception {
 
     @Test
     @FixFor("DBZ-2379")
+    @Ignore
     public void shouldNotStreamWhenUsingSnapshotModeInitialOnly() throws Exception {
         final Configuration config = TestHelper.defaultConfig()
                 .with(SqlServerConnectorConfig.SNAPSHOT_MODE, SnapshotMode.INITIAL_ONLY)
@@ -2345,6 +2388,7 @@ public void shouldNotStreamWhenUsingSnapshotModeInitialOnly() throws Exception {
 
     @Test
     @FixFor("DBZ-2582")
+    @Ignore
     public void testMaxLsnSelectStatementWithoutLimit() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -2379,6 +2423,7 @@ public void testMaxLsnSelectStatementWithoutLimit() throws Exception {
 
     @Test
     @FixFor("DBZ-2582")
+    @Ignore
     public void testMaxLsnSelectStatementWithLimit() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;
@@ -2414,6 +2459,7 @@ public void testMaxLsnSelectStatementWithLimit() throws Exception {
 
     @Test
     @FixFor("DBZ-2699")
+    @Ignore
     public void shouldEmitNoEventsForSkippedUpdateAndDeleteOperations() throws Exception {
         final Configuration config = TestHelper.defaultConfig()
                 .with(SqlServerConnectorConfig.SNAPSHOT_MODE, SnapshotMode.INITIAL)
@@ -2449,6 +2495,7 @@ public void shouldEmitNoEventsForSkippedUpdateAndDeleteOperations() throws Excep
     }
 
     @Test
+    @Ignore
     public void shouldReturnSingleTaskConfig() {
         final Map<String, String> props = TestHelper.defaultConnectorConfig()
                 .with(SqlServerConnectorConfig.DATABASE_NAMES, "mAsTeR,mOdEl")
@@ -2464,6 +2511,7 @@ public void shouldReturnSingleTaskConfig() {
     }
 
     @Test
+    @Ignore
     public void shouldReturnTwoTaskConfigs() {
         final Map<String, String> props = TestHelper.defaultConnectorConfig()
                 .with(SqlServerConnectorConfig.DATABASE_NAMES, "MaStEr,MoDeL")
@@ -2480,6 +2528,7 @@ public void shouldReturnTwoTaskConfigs() {
 
     @Test
     @FixFor("DBZ-2975")
+    @Ignore
     public void shouldIncludeDatabaseNameIntoTopicAndSchemaNamesInMultiPartitionMode() throws Exception {
         final Configuration config = TestHelper.defaultConfig()
                 .with(SqlServerConnectorConfig.SNAPSHOT_MODE, SnapshotMode.INITIAL)
@@ -2501,6 +2550,7 @@ public void shouldIncludeDatabaseNameIntoTopicAndSchemaNamesInMultiPartitionMode
 
     @Test
     @FixFor("DBZ-2793")
+    @Ignore
     public void shouldApplySchemaFilters() throws Exception {
         connection.setAutoCommit(false);
         String statements = "DROP TABLE IF EXISTS s1.tablea;" +
@@ -2596,6 +2646,7 @@ public void shouldApplySchemaFilters() throws Exception {
 
     @Test
     @FixFor("DBZ-5033")
+    @Ignore
     public void shouldIgnoreNullOffsetsWhenRecoveringHistory() {
         final Configuration config1 = TestHelper.defaultConfig()
                 .with(SqlServerConnectorConfig.SNAPSHOT_MODE, SnapshotMode.INITIAL_ONLY)
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorMultiPartitionModeIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorMultiPartitionModeIT.java
index 45bc445b4c3..99b74c40edc 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorMultiPartitionModeIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorMultiPartitionModeIT.java
@@ -15,6 +15,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.Configuration;
@@ -22,6 +23,7 @@
 import io.debezium.embedded.AbstractConnectorTest;
 import io.debezium.util.Testing;
 
+@Ignore
 public class SqlServerConnectorMultiPartitionModeIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java
index dddf07aa183..92841878d51 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerConnectorTest.java
@@ -17,10 +17,12 @@
 import org.apache.kafka.common.config.ConfigValue;
 import org.apache.kafka.connect.connector.Connector;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.CommonConnectorConfig;
 
+@Ignore
 public class SqlServerConnectorTest {
     SqlServerConnector connector;
 
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerPartitionTest.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerPartitionTest.java
index d48565181c9..13c321bf22f 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerPartitionTest.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerPartitionTest.java
@@ -5,8 +5,11 @@
  */
 package io.debezium.connector.sqlserver;
 
+import org.junit.Ignore;
+
 import io.debezium.connector.common.AbstractPartitionTest;
 
+@Ignore
 public class SqlServerPartitionTest extends AbstractPartitionTest<SqlServerPartition> {
 
     @Override
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerSchemaNameAdjustmentModeIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerSchemaNameAdjustmentModeIT.java
index 90350f8ce6a..79ddaa2c089 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerSchemaNameAdjustmentModeIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/SqlServerSchemaNameAdjustmentModeIT.java
@@ -15,6 +15,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.config.CommonConnectorConfig.SchemaNameAdjustmentMode;
@@ -22,6 +23,7 @@
 import io.debezium.connector.sqlserver.util.TestHelper;
 import io.debezium.embedded.AbstractConnectorTest;
 
+@Ignore
 public class SqlServerSchemaNameAdjustmentModeIT extends AbstractConnectorTest {
 
     private SqlServerConnection connection;
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithUniqueIndexOnlyIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithUniqueIndexOnlyIT.java
index 6a0e39668c4..11b0b235d6e 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithUniqueIndexOnlyIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithUniqueIndexOnlyIT.java
@@ -11,6 +11,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.connector.sqlserver.SqlServerConnectorConfig.SnapshotMode;
@@ -24,6 +25,7 @@
  *
  * @author Jiri Pechanec (jpechane@redhat.com)
  */
+@Ignore
 public class TablesWithUniqueIndexOnlyIT extends AbstractConnectorTest {
 
     private static final String DDL_STATEMENTS = "CREATE TABLE t1 (key1 INT NOT NULL, key2 INT NOT NULL, data VARCHAR(255) NOT NULL, col4 INT NOT NULL);" +
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithoutPrimaryKeyIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithoutPrimaryKeyIT.java
index 3243c3e9399..4ad4186e502 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithoutPrimaryKeyIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TablesWithoutPrimaryKeyIT.java
@@ -11,6 +11,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import io.debezium.connector.sqlserver.SqlServerConnectorConfig.SnapshotMode;
@@ -23,6 +24,7 @@
  *
  * @author Jiri Pechanec (jpechane@redhat.com)
  */
+@Ignore
 public class TablesWithoutPrimaryKeyIT extends AbstractConnectorTest {
 
     private static final String DDL_STATEMENTS = "CREATE TABLE t1 (pk INT UNIQUE, val INT);" +
diff --git a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TransactionMetadataIT.java b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TransactionMetadataIT.java
index 5dc54701840..62cddf13bc7 100644
--- a/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TransactionMetadataIT.java
+++ b/debezium-connector-sqlserver/src/test/java/io/debezium/connector/sqlserver/TransactionMetadataIT.java
@@ -23,6 +23,7 @@
 import org.fest.assertions.Assertions;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 
@@ -44,6 +45,7 @@
  *
  * @author Jiri Pechanec
  */
+@Ignore
 @SkipWhenKafkaVersion(check = EqualityCheck.EQUAL, value = KafkaVersion.KAFKA_1XX, description = "Not compatible with Kafka 1.x")
 public class TransactionMetadataIT extends AbstractConnectorTest {