docs: public static CanalConnector newClusterConnector(List<? extends SocketAddress> addresses, String destination,
                                                       String username, String password) {
          ClusterCanalConnector canalConnector = new ClusterCanalConnector(username,
              password,
              destination,
              new SimpleNodeAccessStrategy(addresses));
          canalConnector.setSoTimeout(60 * 1000);
          canalConnector.setIdleTimeout(60 * 60 * 1000);
          return canalConnector;
      }