Hello Beam Team, I am using apache beam for reading from Kafka using KafkaIO in Dataflow Runner. Here I am facing an issue to make KafkaIO Parameters (like -> Config, topics) dynamic. I mean, when I am making these parameters as a PipelineOptions using RuntimeValueProvider My Dataflow Template is not getting created and getting errors that KafkaIO does not support RuntimeValueProvider. So in this case can you please suggest or give any sample code to make these parameters as PipelineOptions.
Thanks & Regards *Himanshu Singhal* M:- +917821076244 E:- singhal.himansh...@gmail.com
