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

2024-02-02 Thread acosentino 
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 32cb0c059c43ed8a9710ac63829494b01c80feaf
Author: Andrea Cosentino 
AuthorDate: Fri Feb 2 14:18:11 2024 +0100

Kafka Batch SSL: Expose also maxPollIntervalMs option

Signed-off-by: Andrea Cosentino 
---
 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'

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

2024-02-02 Thread acosentino 
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 
AuthorDate: Fri Feb 2 14:18:11 2024 +0100

Kafka Batch SSL: Expose also maxPollIntervalMs option

Signed-off-by: Andrea Cosentino 
---
 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'