This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 2379
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3b9ef19550f30662fe861aaa114d14f6870cc786
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Feb 12 15:23:20 2025 +0100
Kafka Batch Source: Reflect changes from CAMEL-21691 - Kafka Batch SSL
Source
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
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 c0634eab..17bcb22b 100644
--- a/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -156,6 +156,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.
@@ -192,6 +196,7 @@ spec:
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
+ batchingIntervalMs: "{{?batchingIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
topicIsPattern: "{{topicIsPattern}}"
