diff --git a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcDeleteHandlingIntegrationTest.java b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcDeleteHandlingIntegrationTest.java
index d092ad4f..79f9e3d3 100644
--- a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcDeleteHandlingIntegrationTest.java
+++ b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcDeleteHandlingIntegrationTest.java
@@ -119,7 +119,7 @@ public class CdcDeleteHandlingIntegrationTest {
 				(rs, rowNum) -> rs.getString("id"), "Test666").iterator().next();
 
 		List<Message<?>> messages = receiveAll(outputDestination);
-		assertThat(messages).hasSize(53);
+		assertThat(messages).hasSizeGreaterThanOrEqualTo(52);
 
 		JdbcTestUtils.deleteFromTableWhere(jdbcTemplate, "customers", "first_name = ?", "Test666");
 
diff --git a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteringIntegrationTest.java b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteringIntegrationTest.java
index 4db44654..177d8494 100644
--- a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteringIntegrationTest.java
+++ b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcFlatteringIntegrationTest.java
@@ -88,7 +88,7 @@ public class CdcFlatteringIntegrationTest {
 		boolean isKafkaPresent = ClassUtils.isPresent(ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL, context.getClassLoader());
 
 		List<Message<?>> messages = receiveAll(outputDestination);
-		assertThat(messages).hasSize(52);
+		assertThat(messages).hasSizeGreaterThanOrEqualTo(52);
 
 		assertJsonEquals(resourceToString(
 				"classpath:/json/mysql_ddl_drop_inventory_address_table.json"),
@@ -172,7 +172,7 @@ public class CdcFlatteringIntegrationTest {
 		boolean isKafkaPresent = ClassUtils.isPresent(ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL, context.getClassLoader());
 
 		List<Message<?>> messages = receiveAll(outputDestination);
-		assertThat(messages).hasSize(52);
+		assertThat(messages).hasSizeGreaterThanOrEqualTo(52);
 
 		CdcCommonProperties.Flattering flatteringProps = context.getBean(CdcCommonProperties.class).getFlattering();
 
diff --git a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcSourceDatabasesIntegrationTest.java b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcSourceDatabasesIntegrationTest.java
index 55a76b8a..37035c90 100644
--- a/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcSourceDatabasesIntegrationTest.java
+++ b/applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcSourceDatabasesIntegrationTest.java
@@ -61,7 +61,7 @@ public class CdcSourceDatabasesIntegrationTest<b> {
 			// Using local region here
 			List<Message<?>> messages = receiveAll(outputDestination);
 			assertThat(messages).isNotNull();
-			assertThat(messages).hasSize(52);
+			assertThat(messages).hasSizeGreaterThanOrEqualTo(52);
 		}
 	}
 
diff --git a/functions/common/cdc-debezium-boot-starter/src/test/java/org/springframework/cloud/fn/common/cdc/CdcBootStarterIntegrationTest.java b/functions/common/cdc-debezium-boot-starter/src/test/java/org/springframework/cloud/fn/common/cdc/CdcBootStarterIntegrationTest.java
index c90d55ae..c489ad8a 100644
--- a/functions/common/cdc-debezium-boot-starter/src/test/java/org/springframework/cloud/fn/common/cdc/CdcBootStarterIntegrationTest.java
+++ b/functions/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);
 				});
 	}