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);
