Consume
yaml
type: "io.kestra.plugin.gcp.pubsub.consume"Examples
yaml
id: gcp_pubsub_consume
namespace: company.team
tasks:
- id: consume
type: io.kestra.plugin.gcp.pubsub.Consume
topic: topic-test
maxRecords: 10
projectId: {{ secret('GCP_PROJECT_ID') }}
subscription: my-subscription
Properties
subscription *Requiredstring
topic *Requiredstring
autoCreateSubscription booleanstring
Default
trueimpersonatedServiceAccount string
maxDuration string
Format
durationmaxRecords integerstring
projectId string
scopes array
SubType string
Default
["https://www.googleapis.com/auth/cloud-platform"]serdeType string
Default
STRING Possible Values
STRINGJSONserviceAccount string
Outputs
count integer
uri string
Format
uri