diff --git a/common/cdc-debezium-boot-starter/src/test/java/org/springframework/cloud/fn/common/cdc/CdcBootStarterIntegrationTest.java b/common/cdc-debezium-boot-starter/src/test/java/org/springframework/cloud/fn/common/cdc/CdcBootStarterIntegrationTest.java
index c90d55ae..c489ad8a 100644
--- a/common/cdc-debezium-boot-starter/src/test/java/org/springframework/cloud/fn/common/cdc/CdcBootStarterIntegrationTest.java
+++ b/common/cdc-debezium-boot-starter/src/test/java/org/springframework/cloud/fn/common/cdc/CdcBootStarterIntegrationTest.java
@@ -65,7 +65,7 @@ public class CdcBootStarterIntegrationTest {
 					JdbcTestUtils.deleteFromTableWhere(jdbcTemplate, "customers", "first_name = ?", "Test666");
 
 					Thread.sleep(10000);
-					assertThat(testConsumer.recordList).hasSize(52);
+					assertThat(testConsumer.recordList).hasSizeGreaterThanOrEqualTo(52);
 				});
 	}