code: 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;
      }
docs: 创建带cluster模式的客户端链接，自动完成failover切换，服务器列表自动扫描
  
  @param zkServers
  @param destination
  @param username
  @param password
  @return