Hi there, I’m trying out a streaming pipeline which reads events from a pubsub topic and I want to pass a side input to the stage that processes this pubsub event, updating the side input value every 5 minutes using an impulse that kicks off a time.Ticker which emits every 5 minutes.
The streaming side using the pubsubio data source didn’t seem to be working in this configuration as pubsub messages were not being acked. However, this normally works without the side input configuration. So my question is, are side inputs available to use in the go sdk running on dataflow? Is there a bug or known issue? Thank you, Kane Knight