DBZ-2464 Add debezium.test.records.waittime support
This commit is contained in:
parent
94a4019f9a
commit
2e800756b8
@ -1491,7 +1491,7 @@ private SourceRecord getUpdateRecord(String database, String collection, String
|
||||
private void assertDocumentContainsFieldError(String fieldName) {
|
||||
final String message = "IllegalArgumentException: Document already contains field : " + fieldName;
|
||||
try {
|
||||
Awaitility.await().atMost(Duration.ofSeconds(30))
|
||||
Awaitility.await().atMost(Duration.ofSeconds(TestHelper.waitTimeForRecords() * 15))
|
||||
.until(() -> logInterceptor.containsStacktraceElement(message));
|
||||
}
|
||||
catch (ConditionTimeoutException e) {
|
||||
|
@ -30,6 +30,8 @@
|
||||
public class TestHelper {
|
||||
protected final static Logger logger = LoggerFactory.getLogger(TestHelper.class);
|
||||
|
||||
private static final String TEST_PROPERTY_PREFIX = "debezium.test.";
|
||||
|
||||
public static Configuration getConfiguration() {
|
||||
return Configuration.fromSystemProperties("connector.").edit()
|
||||
.withDefault(MongoDbConnectorConfig.HOSTS, "rs0/localhost:27017")
|
||||
@ -85,4 +87,8 @@ public static Document getDocumentWithoutLanguageVersion(String jsonString) {
|
||||
document.remove("$v");
|
||||
return document;
|
||||
}
|
||||
|
||||
public static int waitTimeForRecords() {
|
||||
return Integer.parseInt(System.getProperty(TEST_PROPERTY_PREFIX + "records.waittime", "2"));
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user