diff --git a/.github/workflows/sqlserver-workflow.yml b/.github/workflows/sqlserver-workflow.yml
index b03d0df8a..9d0cd2926 100644
--- a/.github/workflows/sqlserver-workflow.yml
+++ b/.github/workflows/sqlserver-workflow.yml
@@ -49,4 +49,4 @@ jobs:
           restore-keys: |
             ${{ runner.os }}-maven-
       - name: Check changes in Debezium Connector SQL Server
-        run: mvn clean install -B -pl debezium-connector-sqlserver -am -Passembly -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
+        run: mvn clean install -B -pl debezium-connector-sqlserver -am -Passembly -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120 -Ddebezium.test.records.waittime=10
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 b65ac3b50..d50b3e44c 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
@@ -147,8 +147,6 @@ public void fail() throws Exception {
                     "INSERT INTO tableb VALUES(" + id + ", 'b')");
         }
 
-        SourceRecords records = consumeRecordsByTopic(1);
-        Assertions.assertThat(records.recordsForTopic("server1.dbo.tablea")).hasSize(1);
         Awaitility.await()
                 .alias("Found warning message in logs")
                 .atMost(TestHelper.waitTimeForRecords(), TimeUnit.SECONDS).until(() -> {