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

[or...@apache.org]

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 <an...@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;