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:

Reply via email to