Hi everyone, I’m working on a PR to PubsubIO that will allow writing to different topics dynamically [1].
PubsubUnboundedSink is replaced by DataFlow runner with internal implementation so it requires changes in the runner. I was able to run the changes in DataFlow by adding the flag “enable_custom_pubsub_sink“ but I guess there is a good reason for the internal replacement. Can someone help with those changes? It was inspired by "BigQuery dynamic destination" and this will have a huge value for my team. [1] - https://github.com/apache/beam/pull/16366 Thanks! Tamir
