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 3d9b61dc6df25ff77e85a7337475953dffbeee1a
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Feb 12 15:53:05 2025 +0100
Kafka Batch Source: Reflect changes from CAMEL-21691 - Kafka Batch Apicurio
Schema Registry Not Secured Source
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 5 +++++
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 5 +++++
2 files changed, 10 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 f27f0be2..29e7381b 100644
--- a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -119,6 +119,10 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when
using consumer group management
type: int
+ batchingIntervalMs:
+ title: Batching Interval
+ description: In consumer batching mode, then this option is specifying
a time in millis, to trigger batch completion eager when the current batch size
has not reached the maximum size defined by maxPollRecords. Notice the trigger
is not exact at the given interval, as this can only happen between kafka polls
(see pollTimeoutMs option).
+ type: int
topicIsPattern:
title: Topic Is Pattern
description: Whether the topic is a pattern (regular expression). This
can be used to subscribe to dynamic number of topics matching the pattern.
@@ -152,6 +156,7 @@ spec:
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
+ batchingIntervalMs: "{{?batchingIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
topicIsPattern: "{{topicIsPattern}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index f27f0be2..29e7381b 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -119,6 +119,10 @@ spec:
title: Max Poll Interval
description: The maximum delay between invocations of poll() when
using consumer group management
type: int
+ batchingIntervalMs:
+ title: Batching Interval
+ description: In consumer batching mode, then this option is specifying
a time in millis, to trigger batch completion eager when the current batch size
has not reached the maximum size defined by maxPollRecords. Notice the trigger
is not exact at the given interval, as this can only happen between kafka polls
(see pollTimeoutMs option).
+ type: int
topicIsPattern:
title: Topic Is Pattern
description: Whether the topic is a pattern (regular expression). This
can be used to subscribe to dynamic number of topics matching the pattern.
@@ -152,6 +156,7 @@ spec:
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
+ batchingIntervalMs: "{{?batchingIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
topicIsPattern: "{{topicIsPattern}}"
