Hi Beam Community, I'm new to Apache Beam and trying to build a pipeline using Go. My requirement is to read a BigQuery table and publish the contents as a PubSub message.
I couldn't find any information on the usage of pubsubio.Write function in the Go module. I want to know how to convert a PCollection to type pubsub.PubsubMessage I have added more details in the StackOverFlow question. https://stackoverflow.com/questions/74760743/apache-beam-write-pubsub-messages-using-go Thank you for the support. Regards, Ashok
