Hi Ananth, It's already code freeze for 1.15 and you can refer to [1] for more details.
Regards, Dian [1] https://www.mail-archive.com/dev@flink.apache.org/msg54262.html On Sun, Feb 20, 2022 at 1:51 AM Ananth Gundabattula < agundabatt...@darwinium.com> wrote: > Thanks a lot Wong. > > > > I was wondering what the timelines are for the 1.15 release (to plan a > things around our CI pipeline). The below information really helps and > thanks for the contribution. > > > > Regards, > > Ananth > > > > *From: *Luning Wong <gfen...@gmail.com> > *Date: *Friday, 18 February 2022 at 6:12 pm > *To: *user@flink.apache.org <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, you could compile the master branch. > When I completed the python connector code, I only tested the native > pulsar protocol without KOP. > > Usage examples are in comments of the PulsarSource class and in test > case of the FlinkPulsarTest class. > You can find them in the following PR link. > https://github.com/apache/flink/pull/18388 > > Best regards, > > Wong > > Xingbo Huang <hxbks...@gmail.com> 于2022年2月18日周五 14:32写道： > > > > > > > > ---------- Forwarded message --------- > > 发件人： Ananth Gundabattula <agundabatt...@darwinium.com> > > Date: 2022年2月17日周四 16:57 > > Subject: Pyflink with pulsar > > To: user@flink.apache.org <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 any advice regarding pulsar as a source > connector available via python ? > > > > Alternately, Pulsar seems to have a kafka protocol handler (KOP) and was > wondering if anyone has built a pyflink application streaming from pulsar > using the Kafka protocol ( By using pyflink kafka consumer ) ? If yes, > could you please share your experiences. > > > > > > Regards, > > Ananth > > > > >
