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 2025/02/12 14:55:30 UTC
(camel-kamelets) 03/07: Kafka Batch Source: Reflect changes from CAMEL-21691 - Kafka Batch SCRAM Source
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 58de6b6506c5ac6e304e2955efe21b22d1585994
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 12 15:21:00 2025 +0100
Kafka Batch Source: Reflect changes from CAMEL-21691 - Kafka Batch SCRAM Source
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-batch-scram-source.kamelet.yaml | 5 +++++
.../main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml | 5 +++++
2 files changed, 10 insertions(+)
diff --git a/kamelets/kafka-batch-scram-source.kamelet.yaml b/kamelets/kafka-batch-scram-source.kamelet.yaml
index b1772ab3..93892b70 100644
--- a/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/kamelets/kafka-batch-scram-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-scram-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
index b1772ab3..93892b70 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-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}}"