请问如何在两个sr集群之间做实时数据同步 并做数据清洗

请问如何在两个sr集群之间做实时数据同步 并做数据清洗,有什么好的方案呢, Flink connector 可以做自定义逻辑的数据清洗吗

什么场景下需要两个sr做实时数据同步呢?