[camel] 03/03: (chores) camel-kafka: ensure poll runs shortly

[orpiske]

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

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 3783eab4584b8e42df926af02651d9ab97f7d2b0
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Wed Aug 3 17:09:28 2022 +0200

    (chores) camel-kafka: ensure poll runs shortly
    
    The default poll duration is longer than the test execution. If no data is 
provided, this can cause the test to fail as the next poll would likely happen 
after the assertion timeout
---
 .../component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
index 398a49eca7f..e88e4209b06 100644
--- 
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
+++ 
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/commit/KafkaConsumerAsyncCommitIT.java
@@ -34,7 +34,7 @@ public class KafkaConsumerAsyncCommitIT extends 
BaseManualCommitTestSupport {
     public static final String TOPIC = "testManualAsyncCommitTest";
 
     @EndpointInject("kafka:" + TOPIC
-                    + 
"?groupId=KafkaConsumerAsyncCommitIT&autoCommitEnable=false"
+                    + 
"?groupId=KafkaConsumerAsyncCommitIT&pollTimeoutMs=1000&autoCommitEnable=false"
                     + 
"&allowManualCommit=true&autoOffsetReset=earliest&kafkaManualCommitFactory=#class:org.apache.camel.component.kafka.consumer.DefaultKafkaManualAsyncCommitFactory")
     private Endpoint from;