docs: @Override
      public CompletableFuture<Void> shutdownAsync(long quietPeriod, long timeout, TimeUnit timeUnit) {
  
          if (clusterTopologyRefreshActivated.compareAndSet(true, false)) {
  
              ScheduledFuture<?> scheduledFuture = clusterTopologyRefreshFuture.get();
  
              try {
                  scheduledFuture.cancel(false);
                  clusterTopologyRefreshFuture.set(null);
              } catch (Exception e) {
                  logger.debug("Could not cancel Cluster topology refresh", e);
              }
          }
  
          return super.shutdownAsync(quietPeriod, timeout, timeUnit);
      }