You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/02/02 13:21:35 UTC
(camel-kamelets) 01/10: Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
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 73464f34564e2d0a745a7b6818401a79fa1674b1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:10:55 2024 +0100
Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index 7b4c787a..0e5e43c3 100644
--- a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/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: