streamnative / pulsar-flink

Elastic data processing with Apache Pulsar and Apache Flink
Apache License 2.0
278 stars 119 forks source link

[FEATURE] Support auto failover in Flink connector #606

Open Lucent-Wong opened 2 years ago

Lucent-Wong commented 2 years ago

Is your feature request related to a problem? Please describe. Currently, to switch the Flink job to the standby Pulsar cluster, it needs to update the job config and start from a former savepoint. With the auto failover feature, I think it can improve the availability of Flink jobs.

Describe the solution you'd like We hope Flink connector of Pulsar can leverage the auto failover feature to improve the availability of Flink jobs.