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

Reply via email to