KafkaIO Parameter Issue | Runtime PipelineOptions | Apche Beam

2023-08-04 Thread himanshu singhal
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

Re: KafkaIO Parameter Issue | Runtime PipelineOptions | Apche Beam

2023-08-10 Thread himanshu singhal
Hello Team, Please update here. Thanks & Regards *Himanshu Singhal* M:- +917821076244 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 Kaf

Re: KafkaIO Parameter Issue | Runtime PipelineOptions | Apche Beam

2023-08-11 Thread himanshu singhal
n the mail list archive > https://lists.apache.org/thread/96vz0pdbc6t159vt82ns90qpft1w9d2w > > > On Thu, Aug 10, 2023 at 11:37 AM himanshu singhal < > singhal.himansh...@gmail.com> wrote: > >> Hello Team, >> Please update here. >> >> >> >> Tha