Search code examples
apache-nifi

How to publish messages on GCP PubSublite from Apache Nifi


Anybody already used GCP CredentialsControllerService and PublishGCPubSubLite processor from Apache Nifi? I'm getting errors, and not found a concrete solution to Publish messages on Pub/Sub lite.

Note: GCP json keys are correct.

Caused by: com.google.api.gax.rpc.UnauthenticatedException: io.grpc.StatusRuntimeException: UNAUTHENTICATED: Request had invalid authentication credentials. Expected OAuth 2 access token, login cookie or other valid authentication credential. See https://developers.google.com/identity/sign-in/web/devconsole-project.


Solution

  • @Yunnosch, Yeah, The solution i got is, add user_authorized key which contains the refresh token can make the connection between nifi and pubsublite.

    "type": "authorized_user"