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`| |=== diff --git a/google-pubsub-source.kamelet.yaml b/google-pubsub-source.kamelet.yaml index 97e74c922..fd4f53181 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: Concurrent Consumers + description: The number of parallel streams consuming from the subscription + 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 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..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 @@ -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: Concurrent Consumers + description: The number of parallel streams consuming from the subscription + 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