Closed wrussell1999 closed 3 months ago
Trying to use the example on https://kestra.io/plugins/plugin-gcp/tasks/pubsub/io.kestra.plugin.gcp.pubsub.consume to consume messages from a Google PubSub topic.
With the topic, serviceAccount and projectId set, it still throws a NullPointerException with no clear indication on what the error is/
id: consume_pubsub namespace: company.team tasks: - id: "consume" type: "io.kestra.plugin.gcp.pubsub.Consume" topic: test-topic projectId: "snappy-nomad-422714-t8" maxRecords: 10 serviceAccount: "{{ secret('GOOGLE_SA') }}"
No response
reproducing
subscription is mandatory, I'll add a check for that and update the example
subscription
Expected Behavior
Trying to use the example on https://kestra.io/plugins/plugin-gcp/tasks/pubsub/io.kestra.plugin.gcp.pubsub.consume to consume messages from a Google PubSub topic.
Actual Behaviour
With the topic, serviceAccount and projectId set, it still throws a NullPointerException with no clear indication on what the error is/
Steps To Reproduce
Environment Information
Example flow
No response