code: public Map<String, String> getControls(Version serverVersion) {
      final CompressionMode effectiveMode = compression(serverVersion);
  
      if (compressionMode != effectiveMode) {
        LOGGER.info("Couchbase Server version {} does not support {} compression mode; falling back to {}.",
            serverVersion, compressionMode, effectiveMode);
      } else {
        LOGGER.debug("Compression mode: {}", compressionMode);
      }
  
      final Map<String, String> result = new HashMap<>(values);
      result.putAll(effectiveMode.getDcpControls(serverVersion));
      return result;
    }
docs: Returns the control settings, adjusted for the actual Couchbase Server version.