You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2026/07/07 14:59:32 UTC
(camel-quarkus) 02/06: Increase KafkaTest timeout
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch 3.33.x
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 12e166edb704cb5d385e24b6ed3a632cb186b7f4
Author: Lukas Lowinger <ll...@redhat.com>
AuthorDate: Mon Jul 6 10:36:17 2026 +0200
Increase KafkaTest timeout
---
.../test/java/org/apache/camel/quarkus/kafka/oauth/it/KafkaTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/integration-tests/kafka-oauth/src/test/java/org/apache/camel/quarkus/kafka/oauth/it/KafkaTest.java b/integration-tests/kafka-oauth/src/test/java/org/apache/camel/quarkus/kafka/oauth/it/KafkaTest.java
index a858d76b8a..914cb3c510 100644
--- a/integration-tests/kafka-oauth/src/test/java/org/apache/camel/quarkus/kafka/oauth/it/KafkaTest.java
+++ b/integration-tests/kafka-oauth/src/test/java/org/apache/camel/quarkus/kafka/oauth/it/KafkaTest.java
@@ -31,7 +31,7 @@ public class KafkaTest {
@Test
public void testKafka() {
- await().atMost(10, TimeUnit.SECONDS).until(() -> {
+ await().atMost(45, TimeUnit.SECONDS).until(() -> {
String message = RestAssured.get("/kafka-oauth").asString();
return message != null && message.contains("Message #");
});