From 775d21a03caa226a22f719527e8e13bec28c5b6a Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 8 Sep 2021 14:20:42 +0200 Subject: [PATCH 1/4] Google Pubsub Source Kamelets Added Concurrent Consumers number parameter --- google-pubsub-source.kamelet.yaml | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/google-pubsub-source.kamelet.yaml b/google-pubsub-source.kamelet.yaml index 97e74c922..2dc150fb0 100644 --- a/google-pubsub-source.kamelet.yaml +++ b/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 From 6e1a6e18acf68767c210fd18bb9bdc95014792b1 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 8 Sep 2021 14:22:39 +0200 Subject: [PATCH 2/4] Google Pubsub Source Kamelets Added Concurrent Consumers number parameter --- google-pubsub-source.kamelet.yaml | 4 ++-- .../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 2dc150fb0..fd4f53181 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 97e74c922..2dc150fb0 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 From 37c7771597cc497b09f042d5d1a4c853159c7d0a Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 8 Sep 2021 14:22:54 +0200 Subject: [PATCH 3/4] Google Pubsub Source Kamelets Added Concurrent Consumers number parameter --- .../main/resources/kamelets/google-pubsub-source.kamelet.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 2dc150fb0..fd4f53181 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 @@ -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: From 30c1ea28e8061d2f5eb86ff76e54a8e1ea3d1e38 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 8 Sep 2021 14:25:21 +0200 Subject: [PATCH 4/4] Google Pubsub Source Kamelets Added Concurrent Consumers number parameter --- docs/modules/ROOT/pages/google-pubsub-source.adoc | 1 + 1 file changed, 1 insertion(+) diff --git a/docs/modules/ROOT/pages/google-pubsub-source.adoc b/docs/modules/ROOT/pages/google-pubsub-source.adoc index e6d25e14c..9858be754 100644 --- a/docs/modules/ROOT/pages/google-pubsub-source.adoc +++ b/docs/modules/ROOT/pages/google-pubsub-source.adoc @@ -18,6 +18,7 @@ The following table summarizes the configuration options available for the `goog | *projectId {empty}* *| Project Id| The Google Cloud PubSub Project Id| string| | | *serviceAccountKey {empty}* *| Service Account Key| The Service account key that can be used as credentials for the PubSub publisher/subscriber| binary| | | *subscriptionName {empty}* *| Subscription Name| The Subscription Name| string| | +| concurrentConsumers| Concurrent Consumers| The number of parallel streams consuming from the subscription| integer| `1`| | maxMessagesPerPoll| Max Messages Per Poll| The max number of messages to receive from the server in a single API call| integer| `1`| | synchronousPull| Synchronous Pull| If Synchronously pull batches of messages is enabled or not| boolean| `false`| |===