Expose maxMessagesPerPoll in AWS S3 Source Kamelet (#1692)

Signed-off-by: Andrea Cosentino <[email protected]>
apache · Oct 16, 2023 · 3a24993 · 3a24993
1 parent 895ef65
commit 3a24993
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git 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
   dataTypes:
     out:
       default: binary
@@ -184,6 +189,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
@@ -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
   dataTypes:
     out:
       default: binary
@@ -184,6 +189,7 @@ spec:
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
         delay: "{{delay}}"
+        maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
       steps:
       - process:
           ref: "{{renameHeaders}}"