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

Reply via email to