In the job I'm implementing, there are a couple of configuration variables that I wnat to change at runtime, such as rate limit at the Kafka source. I know it's possible to use a control stream and join it with the normal stream to configure things in certain operators, but this doesn't work for the source. Is there any other way to configure settings at runtime?
Thanks, -- Ning
