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 <[email protected]>
AuthorDate: Wed Mar 11 13:56:19 2026 +0100

    Provide a timeout when joining threads in kafkaTransactionIt test
    
    Signed-off-by: AurĂ©lien Pupier <[email protected]>
---
 .../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);

Reply via email to