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 2d3b4cda..a1824759 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
@@ -124,7 +124,7 @@ public class CdcDeleteHandlingIntegrationTest extends CdcTestSupport {
 		}
 
 		if (!isDropTombstones && isKafkaPresent) {
-			received = outputDestination.receive(Duration.ofSeconds(10000).toMillis());
+			received = outputDestination.receive(Duration.ofSeconds(10).toMillis());
 			assertThat(received).isNotNull();
 			// Tombstones event should have KafkaNull payload
 			assertThat(received.getPayload().getClass().getCanonicalName())
@@ -135,7 +135,7 @@ public class CdcDeleteHandlingIntegrationTest extends CdcTestSupport {
 			assertThat(key).isEqualTo("{\"id\":" + newRecordId + "}");
 		}
 
-		received = outputDestination.receive(Duration.ofSeconds(10).toMillis());
+		received = outputDestination.receive(Duration.ofSeconds(1).toMillis());
 		assertThat(received).isNull();
 	};
 }