| commit | 3a13a0c61e5feac0635582082c771b2743e95c67 | [log] [tgz] |
|---|---|---|
| author | Jang-Vijay Singh <jvsing@gmail.com> | Mon May 06 08:58:43 2024 +0100 |
| committer | GitHub <noreply@github.com> | Mon May 06 09:58:43 2024 +0200 |
| tree | a3f30b7269c3519ec07207722d3c2d631a795c66 | |
| parent | 41055cd98726d6f0ed32c913940867bd8770c43c [diff] |
CAMEL-20722 - changed timeout to 10 sec from 3 in more tests after random & sporadic failures during local testing (#14052) * CAMEL-20722: changed timeout to 10 sec from 3 in KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT * CAMEL-20722 - changed timeout to 10 sec from 3 (sporadic timeout failures on local tests)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java index 8778256..8ac1817 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorWithBatchUsingSyncCommitManagerIT.java
@@ -96,7 +96,7 @@ contextExtension.getContext().getRouteController().startRoute(ROUTE_ID); Awaitility.await() - .atMost(3, TimeUnit.SECONDS) + .atMost(10, TimeUnit.SECONDS) // changed to 10 sec for CAMEL-20722 .until(() -> errorPayloads.size() > 3); to.assertIsSatisfied();
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java index 2100e46..d76bf88 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
@@ -127,7 +127,7 @@ producer.send(data); } - Awaitility.await().atMost(3, TimeUnit.SECONDS).untilAsserted(() -> to.assertIsSatisfied()); + Awaitility.await().atMost(10, TimeUnit.SECONDS).untilAsserted(() -> to.assertIsSatisfied()); // changed to 10 sec for CAMEL-20722 List<Exchange> exchangeList = to.getExchanges(); assertEquals(5, exchangeList.size());