Skip to content
Discussion options

You must be logged in to vote

In the gcp_pubsub source, api_key never reaches Google. That's why you get "unregistered callers". The source talks gRPC through tonic. Vector adds the key as ?key=... on the endpoint URI (src/gcp.rs, apply_uri). Tonic only keeps the endpoint's scheme and host, and the path comes from the RPC method (/google.pubsub.v1.Subscriber/StreamingPull), so the query string is thrown away. With an API key, make_token() returns nothing, so no authorization metadata is sent either. The request arrives with no identity at all.

Use a service account instead. You're on EC2, so there's no GCE metadata server to fall back on. Give the source a service account JSON key that has roles/pubsub.subscriber on t…

Replies: 1 comment 1 reply

Comment options

You must be logged in to vote
1 reply
@pront
Comment options

Answer selected by pront
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
sink: gcp_pubsub Anything `gcp_pubsub` sink related source: gcp_pubsub Anything `gcp_pubsub` source related
3 participants