public static CanalConnector newClusterConnector(String zkServers, String destination, String username,
                                                     String password) {
        ClusterCanalConnector canalConnector = new ClusterCanalConnector(username,
            password,
            destination,
            new ClusterNodeAccessStrategy(destination, ZkClientx.getZkClient(zkServers)));
        canalConnector.setSoTimeout(60 * 1000);
        canalConnector.setIdleTimeout(60 * 60 * 1000);
        return canalConnector;
    }
public static CanalConnector newClusterConnector ( String zkServers , String destination , String username , String password ) { ClusterCanalConnector canalConnector = new ClusterCanalConnector ( username , password , destination , new ClusterNodeAccessStrategy ( destination , ZkClientx . getZkClient ( zkServers ) ) ) ; canalConnector . setSoTimeout ( 60 * 1000 ) ; canalConnector . setIdleTimeout ( 60 * 60 * 1000 ) ; return canalConnector ; }
创建带cluster模式的客户端链接，自动完成failover切换，服务器列表自动扫描

@param zkServers
@param destination
@param username
@param password
@return