docs: public void closeConnection(String clusterName) {
          synchronized (connections) {
              if (connections.containsKey(clusterName)) {
                  connections.get(clusterName).close();
                  connections.remove(clusterName);
              }
          }
          logger.info("Disconnected from [" + clusterName + "]");
      }