[camel-spring-boot] branch main updated: CAMEL-19861: camel-kafka - Increase the result wait time (#938)

[nfilotto]

This is an automated email from the ASF dual-hosted git repository.

nfilotto pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git


The following commit(s) were added to refs/heads/main by this push:
     new 38711bd76c7 CAMEL-19861: camel-kafka - Increase the result wait time 
(#938)
38711bd76c7 is described below

commit 38711bd76c7f4bd5126e7bd676b1fbb81abb69d5
Author: Nicolas Filotto <essob...@users.noreply.github.com>
AuthorDate: Wed Sep 13 14:21:19 2023 +0200

    CAMEL-19861: camel-kafka - Increase the result wait time (#938)
    
    ## Motivation
    
    The test `KafkaConsumerIdempotentWithProcessorIT` fails randomly on the CI.
    
    ## Modifications:
    
    * Increase the result wait time to 20 seconds
---
 .../component/kafka/integration/KafkaConsumerIdempotentTestSupport.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
 
b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
index dc563233617..f19fab8cf52 100644
--- 
a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
+++ 
b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
@@ -57,7 +57,7 @@ public abstract class KafkaConsumerIdempotentTestSupport 
extends BaseEmbeddedKaf
         List<Exchange> exchangeList = mockEndpoint.getReceivedExchanges();
 
         mockEndpoint.assertIsSatisfied(10000);
-
+        mockEndpoint.setResultWaitTime(20_000);
         assertEquals(size, exchangeList.size());
 
         Map<String, Object> headers = 
mockEndpoint.getExchanges().get(0).getIn().getHeaders();