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 2023/10/16 08:56:40 UTC
[camel-kamelets] branch 4.0.x updated: Expose maxMessagesPerPoll in AWS S3 Source Kamelet (#1693)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 4.0.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/4.0.x by this push:
new e9889610 Expose maxMessagesPerPoll in AWS S3 Source Kamelet (#1693)
e9889610 is described below
commit e98896100769321187365083590a49402164a3cd
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Oct 16 10:56:34 2023 +0200
Expose maxMessagesPerPoll in AWS S3 Source Kamelet (#1693)
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/aws-s3-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/aws-s3-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/beer-source.kamelet.yaml | 2 ++
3 files changed, 14 insertions(+)
diff --git a/kamelets/aws-s3-source.kamelet.yaml b/kamelets/aws-s3-source.kamelet.yaml
index c88d7eac..cfd13182 100644
--- a/kamelets/aws-s3-source.kamelet.yaml
+++ b/kamelets/aws-s3-source.kamelet.yaml
@@ -101,6 +101,11 @@ spec:
description: The number of milliseconds before the next poll of the selected bucket.
type: integer
default: 500
+ maxMessagesPerPoll:
+ title: Max Messages Per Poll
+ description: Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited.
+ type: integer
+ default: 10
dependencies:
- "camel:core"
- "camel:aws2-s3"
@@ -129,6 +134,7 @@ spec:
uriEndpointOverride: "{{?uriEndpointOverride}}"
overrideEndpoint: "{{overrideEndpoint}}"
delay: "{{delay}}"
+ maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
steps:
- process:
ref: "{{renameHeaders}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
index c88d7eac..cfd13182 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
@@ -101,6 +101,11 @@ spec:
description: The number of milliseconds before the next poll of the selected bucket.
type: integer
default: 500
+ maxMessagesPerPoll:
+ title: Max Messages Per Poll
+ description: Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited.
+ type: integer
+ default: 10
dependencies:
- "camel:core"
- "camel:aws2-s3"
@@ -129,6 +134,7 @@ spec:
uriEndpointOverride: "{{?uriEndpointOverride}}"
overrideEndpoint: "{{overrideEndpoint}}"
delay: "{{delay}}"
+ maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
steps:
- process:
ref: "{{renameHeaders}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/beer-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/beer-source.kamelet.yaml
index 811ffc75..f671cc7e 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/beer-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/beer-source.kamelet.yaml
@@ -36,4 +36,6 @@ spec:
period: "{{period}}"
steps:
- to: https://random-data-api.com/api/beer/random_beer
+ - removeHeaders:
+ pattern: '*'
- to: "kamelet:sink"