Hello Beam Team, I am trying to write a custom streaming pubsub input source that requires authenticating with google cloud given the supplied credentials (the credentials may be different than the google cloud environment the pipeline is running in). My input source works if I run the pipeline on Dataflow in batch mode but hangs indefinitely when I run in streaming mode. I’m wondering if there is a special requirement when writing custom streaming input sources?
Thank you, Taiga
