*Motivation*

This ports apache/flink#6200 to apache pulsar repo. It adds a pulsar source 
connector
which will enable flink jobs to process messages from pulsar topics.

*Changes*

Add a PulsarConsumerSource connector



[ Full content available at: 
https://github.com/apache/incubator-pulsar/pull/2555 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to