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 824c6678dc96ef0dddf3b5b4df1ff71cab5c3585
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Feb 2 14:20:59 2024 +0100
Kafka Batch SSL: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
.../src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
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
index 5d6f4ad8..1c2dd340 100644
---
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'
