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
