Re: Pyflink with pulsar

2022-02-22 Thread Dian Fu
ng > *Date: *Friday, 18 February 2022 at 6:12 pm > *To: *user@flink.apache.org , Ananth Gundabattula < > agundabatt...@darwinium.com> > *Subject: *Re: Pyflink with pulsar > > The Pulsar python source connector will be released in 1.15 version. > if you want to use it right now,

Re: Pyflink with pulsar

2022-02-19 Thread Ananth Gundabattula
, Ananth Gundabattula Subject: Re: Pyflink with pulsar The Pulsar python source connector will be released in 1.15 version. if you want to use it right now, you could compile the master branch. When I completed the python connector code, I only tested the native pulsar protocol without KOP

Re: Pyflink with pulsar

2022-02-17 Thread Luning Wong
2022年2月17日周四 16:57 > Subject: Pyflink with pulsar > To: user@flink.apache.org > > > Hello All, > > I am trying to build a pyflink application and I currently have a pulsar > instance that I need to connect and start streaming messages from. > > I was wondering if there is a

Pyflink with pulsar

2022-02-17 Thread Ananth Gundabattula
Hello All, I am trying to build a pyflink application and I currently have a pulsar instance that I need to connect and start streaming messages from. I was wondering if there is any advice regarding pulsar as a source connector available via python ? Alternately, Pulsar seems to have a kafka