You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ap...@apache.org on 2026/03/11 14:59:08 UTC
(camel) 01/02: Provide a timeout when joining threads in kafkaTransactionIt test
This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 0a008dee03426f80fc28c5128122fbab660f15e2
Author: Aurélien Pupier <ap...@ibm.com>
AuthorDate: Wed Mar 11 13:56:19 2026 +0100
Provide a timeout when joining threads in kafkaTransactionIt test
Signed-off-by: Aurélien Pupier <ap...@ibm.com>
---
.../apache/camel/component/kafka/integration/KafkaTransactionIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaTransactionIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaTransactionIT.java
index 5569d15e0169..01128c35678a 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaTransactionIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaTransactionIT.java
@@ -119,7 +119,7 @@ public class KafkaTransactionIT extends BaseKafkaTestSupport {
}
for (int i = 0; i < THREAD_NUM; i++) {
- threads[i].join();
+ threads[i].join(30000);
}
createKafkaMessageConsumer(stringsConsumerConn, TOPIC_CONCURRENCY_TRANSACTION, messagesLatch);