This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch g-pubsub-1
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 6e1a6e18acf68767c210fd18bb9bdc95014792b1
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

Reply via email to