Kafka Batch SSL: Expose also maxPollIntervalMs option

Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Feb 2, 2024 · cea5382 · cea5382
1 parent 32cb0c0
commit cea5382
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/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'