We are now done with the Flink Pulsar connector. It is ready to be merged. Now our plan is
1. merge Source and Sink based on Function, because it has been verified by users and is reliable. 2. Next is to merge the DynamicTable feature. table implementation depends on Step 1. 3. merge Pulsar Catalog 4. merge the PulsarSource based on FLIP-27: Refactor Source Interface<https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface> of PulsarSource 5. merge PulsarSink based on FLIP-143: Unified Sink API<https://cwiki.apache.org/confluence/display/FLINK/FLIP-143%3A+Unified+Sink+API> 6. merge upsert-pulsar About wiki, I need to update the FLIP-72: Introduce Pulsar Connector<https://cwiki.apache.org/confluence/display/FLINK/FLIP-72%3A+Introduce+Pulsar+Connector>, but I don't have access to it. StreamNative/Pulsar Flink Connector: https://github.com/streamnative/pulsar-flink Looking forward to your feedback~ Jianyun Zhao