dpcollins-google commented on pull request #16366: URL: https://github.com/apache/beam/pull/16366#issuecomment-1001875299
Hi Tamir, Thank you for your contribution to beam. Changes to PubsubIO like this will not properly work on dataflow jobs, as the dataflow runner replaces Pub/Sub reads and writes with an internal implementation. If you want to dynamically dispatch to Pub/Sub Topics for your own pipelines, you might be able to get this working in the shorter term by writing a relatively simple DoFn using the Pub/Sub java client library in your code that identifies the topic from an attribute and publishes to the correct topic. If this is a feature that you'd like to see added to PubsubIO, I'd suggest bringing it up on the dev mailing list, where you could coordinate and discuss this with the owners of the internal runner. -Daniel -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
