This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 607a8446e53e35070426c6e5ea8f8995fb9b8779 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Fri Feb 2 14:11:38 2024 +0100 Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml index 7b4c787a..0e5e43c3 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml @@ -115,6 +115,10 @@ spec: description: The timeout used when polling the KafkaConsumer type: int default: 5000 + maxPollIntervalMs: + title: Max Poll Interval + description: The maximum delay between invocations of poll() when using consumer group management + type: int dependencies: - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT" - "camel:kafka" @@ -143,6 +147,7 @@ spec: additionalProperties.apicurio.registry.avro-datum-provider: "{{avroDatumProvider}}" maxPollRecords: "{{batchSize}}" pollTimeoutMs: "{{pollTimeout}}" + maxPollIntervalMs: "{{?maxPollIntervalMs}}" batching: true kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}" steps: