This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 81fe3dc995ceffd73647da3bace10c7844a7c756 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Wed Sep 8 14:22:39 2021 +0200 Google Pubsub Source Kamelets Added Concurrent Consumers number parameter --- google-pubsub-source.kamelet.yaml | 4 ++-- .../src/main/resources/kamelets/google-pubsub-source.kamelet.yaml | 6 ++++++ 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/google-pubsub-source.kamelet.yaml b/google-pubsub-source.kamelet.yaml index 2dc150f..fd4f531 100644 --- a/google-pubsub-source.kamelet.yaml +++ b/google-pubsub-source.kamelet.yaml @@ -48,8 +48,8 @@ spec: type: integer default: 1 concurrentConsumers: - title: Max Messages Per Poll - description: The max number of messages to receive from the server in a single API call + title: Concurrent Consumers + description: The number of parallel streams consuming from the subscription type: integer default: 1 dependencies: diff --git a/library/camel-kamelets/src/main/resources/kamelets/google-pubsub-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/google-pubsub-source.kamelet.yaml index 97e74c9..2dc150f 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/google-pubsub-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/google-pubsub-source.kamelet.yaml @@ -47,6 +47,11 @@ spec: description: The max number of messages to receive from the server in a single API call type: integer default: 1 + concurrentConsumers: + title: Max Messages Per Poll + description: The max number of messages to receive from the server in a single API call + type: integer + default: 1 dependencies: - "camel:kamelet" - "camel:google-pubsub" @@ -58,5 +63,6 @@ spec: serviceAccountKey: "base64:{{serviceAccountKey}}" synchronousPull: "{{synchronousPull}}" maxMessagesPerPoll: "{{maxMessagesPerPoll}}" + concurrentConsumers: "{{concurrentConsumers}}" steps: - to: kamelet:sink