This repository is maintained by StreamNative to host a StreamNative fork of the Flink Connector for Pulsar. Only the Flink Connector for Pulsar (including the Flink SQL Connector for Pulsar and the Flink DataStream Connector for Pulsar) diverges with the official Apache Flink repository.
The following is some useful documentation and resources for the DataStream and SQL Connectors
- Flink SQL Connector for Pulsar documentation
- flink-example: cookbooks, examples
- StreamNative Hub documentation
The legacy pulsar-flink connector is deprecated. It will not be actively maintained and users are recommended to use this repository.