(camel-kamelets) 09/10: Kafka Batch SSL: Expose also maxPollIntervalMs option

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 47093120a5831c823522212d2cfaa76e9c3d492b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:18:11 2024 +0100

    Kafka Batch SSL: Expose also maxPollIntervalMs option
    
    Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
 kamelets/kafka-batch-ssl-source.kamelet.yaml | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/kamelets/kafka-batch-ssl-source.kamelet.yaml b/kamelets/kafka-batch-ssl-source.kamelet.yaml
index 5d6f4ad8..1c2dd340 100644
--- a/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -152,6 +152,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:core"
@@ -183,6 +187,7 @@ spec:
           saslJaasConfig: '{{?saslJaasConfig}}'
           maxPollRecords: "{{batchSize}}"
           pollTimeoutMs: "{{pollTimeout}}"
+          maxPollIntervalMs: "{{?maxPollIntervalMs}}"
           batching: true
           kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
         type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'