Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Google Pubsub Source Kamelet #493

Merged
merged 4 commits into from
Sep 8, 2021
Merged

Google Pubsub Source Kamelet #493

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
775d21a
Google Pubsub Source Kamelets Added Concurrent Consumers number param…
oscerd Sep 8, 2021
6e1a6e1
Google Pubsub Source Kamelets Added Concurrent Consumers number param…
oscerd Sep 8, 2021
37c7771
Google Pubsub Source Kamelets Added Concurrent Consumers number param…
oscerd Sep 8, 2021
30c1ea2
Google Pubsub Source Kamelets Added Concurrent Consumers number param…
oscerd Sep 8, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions docs/modules/ROOT/pages/google-pubsub-source.adoc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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`|
|===
Expand Down
6 changes: 6 additions & 0 deletions google-pubsub-source.kamelet.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand All @@ -58,5 +63,6 @@ spec:
serviceAccountKey: "base64:{{serviceAccountKey}}"
synchronousPull: "{{synchronousPull}}"
maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
concurrentConsumers: "{{concurrentConsumers}}"
steps:
- to: kamelet:sink
6 changes: 6 additions & 0 deletions library/camel-kamelets/src/main/resources/kamelets/google-pubsub-source.kamelet.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand All @@ -58,5 +63,6 @@ spec:
serviceAccountKey: "base64:{{serviceAccountKey}}"
synchronousPull: "{{synchronousPull}}"
maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
concurrentConsumers: "{{concurrentConsumers}}"
steps:
- to: kamelet:sink