[
https://issues.apache.org/jira/browse/FLINK-34091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837152#comment-17837152
]
Yufan Sheng commented on FLINK-34091:
-------------------------------------
Since this is a requirement from Pulsar side. I don't think connector should
care about such huge requirements. The connector only wraps the pulsar client
and expose all its available configuration options.
BTW, pr is welcome for adding such big feature. The pulsar sink has support the
geo replication.
https://github.com/apache/flink-connector-pulsar/blob/9f4b902c2a478d0105eec1e32bac3ea40f318d00/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message/PulsarMessageBuilder.java#L116
Maybe you can check it and add the support in the source side.
> Flink pulsar connect add automatic failover capability
> ------------------------------------------------------
>
> Key: FLINK-34091
> URL: https://issues.apache.org/jira/browse/FLINK-34091
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Pulsar
> Affects Versions: 1.18.0
> Reporter: yangyijun
> Priority: Major
>
> For some business scenarios with high SLA support capabilities, we need to
> support automated cross cluster disaster recovery capabilities. However, the
> current flick pulsar connect does not have this disaster tolerance capability.
> We hope to support the following scenarios:
> 1. master slave hot standby;
> 2. double live (It can support double write or a cluster sharing half of the
> traffic.);
> 3.Multi activity disaster recovery;
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
