(camel-kamelets) 03/10: Kafka Batch Azure 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 af418be784afac060dcd1bee0b3d4b1984f76335 Author: Andrea Cosentino AuthorDate: Fri Feb 2 14:12:30 2024 +0100 Kafka Batch Azure Source: Expose also maxPollIntervalMs option Signed-off-by: Andrea Cosentino --- kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 5 + 1 file changed, 5 insertions(+) diff --git a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml index a83ad6ed..82d21574 100644 --- a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml +++ b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml @@ -135,6 +135,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" @@ -169,6 +173,7 @@ spec: valueDeserializer: "{{valueDeserializer}}" maxPollRecords: "{{batchSize}}" pollTimeoutMs: "{{pollTimeout}}" +maxPollIntervalMs: "{{?maxPollIntervalMs}}" batching: true kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}" additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
(camel-kamelets) 03/10: Kafka Batch Azure Source: Expose also maxPollIntervalMs option
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 5794ddc7f81239785b5538b5852068dd9b76beca Author: Andrea Cosentino AuthorDate: Fri Feb 2 14:12:30 2024 +0100 Kafka Batch Azure Source: Expose also maxPollIntervalMs option Signed-off-by: Andrea Cosentino --- kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 5 + 1 file changed, 5 insertions(+) diff --git a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml index a83ad6ed..82d21574 100644 --- a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml +++ b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml @@ -135,6 +135,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" @@ -169,6 +173,7 @@ spec: valueDeserializer: "{{valueDeserializer}}" maxPollRecords: "{{batchSize}}" pollTimeoutMs: "{{pollTimeout}}" +maxPollIntervalMs: "{{?maxPollIntervalMs}}" batching: true kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}" additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"