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 <[email protected]> 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;
