(camel-kamelets) 01/07: Kafka Batch Source: Reflect changes from CAMEL-21691 - Kafka Batch Source Kamelet

[acosentino]

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 4fdbd1d13715e315f9fdbdfb922ae8ae492b16cf
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Feb 12 14:45:27 2025 +0100

    Kafka Batch Source: Reflect changes from CAMEL-21691 - Kafka Batch Source 
Kamelet
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 kamelets/kafka-batch-source.kamelet.yaml                             | 5 +++++
 .../src/main/resources/kamelets/kafka-batch-source.kamelet.yaml      | 5 +++++
 2 files changed, 10 insertions(+)

diff --git a/kamelets/kafka-batch-source.kamelet.yaml 
b/kamelets/kafka-batch-source.kamelet.yaml
index 60d8f00c..333c8fa0 100644
--- a/kamelets/kafka-batch-source.kamelet.yaml
+++ b/kamelets/kafka-batch-source.kamelet.yaml
@@ -132,6 +132,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.
@@ -164,6 +168,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-source.kamelet.yaml
 
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
index 60d8f00c..333c8fa0 100644
--- 
a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
+++ 
b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
@@ -132,6 +132,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.
@@ -164,6 +168,7 @@ spec:
         maxPollRecords: "{{batchSize}}"
         pollTimeoutMs: "{{pollTimeout}}"
         maxPollIntervalMs: "{{?maxPollIntervalMs}}"
+        batchingIntervalMs: "{{?batchingIntervalMs}}"
         batching: true
         kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"      
         topicIsPattern: "{{topicIsPattern}}"