From 06cf0c473aca3de115da44dded4560af426f1f5c Mon Sep 17 00:00:00 2001 From: David Turanski Date: Thu, 5 Nov 2020 08:52:43 -0500 Subject: [PATCH] Reduce receive timeout --- .../app/source/cdc/CdcDeleteHandlingIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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(); }; }