I am not entirely sure what you try to do with PipelineOptions. Assuming you use Beam Java, https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/options/PipelineOptions.html documents how to construct PipelineOptions is via command-line argument parsing. https://github.com/GoogleCloudPlatform/dataflow-cookbook/blob/main/Java/src/main/java/kafka/ReadKafka.java has some code samples.
On Thu, Aug 10, 2023 at 11:37 AM himanshu singhal < singhal.himansh...@gmail.com> wrote: > Hello Team, > Please update here. > > > > Thanks & Regards > *Himanshu Singhal* > M:- +917821076244 <+91%2078210%2076244> > E:- singhal.himansh...@gmail.com > > > On Sat, Aug 5, 2023 at 8:31 AM himanshu singhal < > singhal.himansh...@gmail.com> wrote: > >> 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 <+91%2078210%2076244> >> E:- singhal.himansh...@gmail.com >> >
