You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/08/03 16:26:18 UTC
[camel] 02/03: (chores) camel-kafka: replace invalid timeout option
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 876622f64e688c2feda251ebd5d4a8352c7d2a60
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Aug 3 17:08:13 2022 +0200
(chores) camel-kafka: replace invalid timeout option
This could cause the client to fail after the test had finished
---
.../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 a74c013a514..398a49eca7f 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&sessionTimeoutMs=30000&autoCommitEnable=false"
+ + "?groupId=KafkaConsumerAsyncCommitIT&autoCommitEnable=false"
+ "&allowManualCommit=true&autoOffsetReset=earliest&kafkaManualCommitFactory=#class:org.apache.camel.component.kafka.consumer.DefaultKafkaManualAsyncCommitFactory")
private Endpoint from;