SpringCloud/stream-applications
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reduce receive timeout

Browse Source
This commit is contained in:
David Turanski
2020-11-05 08:52:43 -05:00
parent f6e4335706
commit 06cf0c473a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
applications/source/cdc-debezium-source/src/test/java/org/springframework/cloud/stream/app/source/cdc/CdcDeleteHandlingIntegrationTest.java
View File

@@ -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();
};
}