Hi everyone, Per discussion in the previous thread <http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Contribute-Pulsar-Flink-connector-back-to-Flink-tc32538.html>, I have created FLIP-72 to kick off a more detailed discussion on the Flink Pulsar connector:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-72%3A+Introduce+Pulsar+Connector In short, the connector has the following features: - Pulsar as a streaming source with exactly-once guarantee. - Sink streaming results to Pulsar with at-least-once semantics. - Build upon Flink new Table API Type system (FLIP-37 <https://cwiki.apache.org/confluence/display/FLINK/FLIP-37%3A+Rework+of+the+Table+API+Type+System> ), and can automatically (de)serialize messages with the help of Pulsar schema. - Integrate with Flink new Catalog API (FLIP-30 <https://cwiki.apache.org/confluence/display/FLINK/FLIP-30%3A+Unified+Catalog+APIs>), which enables the use of Pulsar topics as tables in Table API as well as SQL client. https://docs.google.com/document/d/1rES79eKhkJxrRfQp1b3u8LB2aPaq-6JaDHDPJIA8kMY/edit#heading=h.28v5v23yeq1u Would love to here your thoughts on this. Best, Yijie
