diff --git a/src/test/java/io/debezium/connector/spanner/AbstractSpannerConnectorIT.java b/src/test/java/io/debezium/connector/spanner/AbstractSpannerConnectorIT.java
index 9efb1ac..dc73231 100644
--- a/src/test/java/io/debezium/connector/spanner/AbstractSpannerConnectorIT.java
+++ b/src/test/java/io/debezium/connector/spanner/AbstractSpannerConnectorIT.java
@@ -66,7 +66,7 @@ public static void after() throws InterruptedException {
     }
 
     public static int waitTimeForRecords() {
-        return Integer.parseInt(System.getProperty(TEST_PROPERTY_PREFIX + "records.waittime", "3"));
+        return Integer.parseInt(System.getProperty(TEST_PROPERTY_PREFIX + "records.waittime", "10"));
     }
 
     protected String getTopicName(Configuration config, String tableName) {