diff --git a/kamelets/aws-s3-source.kamelet.yaml b/kamelets/aws-s3-source.kamelet.yaml index c38cc9900..96f2fa096 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 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 index c38cc9900..96f2fa096 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 dataTypes: out: default: binary @@ -184,6 +189,7 @@ spec: uriEndpointOverride: "{{?uriEndpointOverride}}" overrideEndpoint: "{{overrideEndpoint}}" delay: "{{delay}}" + maxMessagesPerPoll: "{{maxMessagesPerPoll}}" steps: - process: ref: "{{renameHeaders}}"