public static void createNamespace(RestTemplate restTemplate, PulsarClusterInfo clusterInfo, String tenant,
            String namespaceName, PulsarNamespacePolicies policies) throws Exception {
        HttpHeaders headers = getHttpHeaders(clusterInfo.getToken());
        MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");
        headers.setContentType(type);
        headers.add("Accept", MediaType.APPLICATION_JSON.toString());
        String param = GSON.toJson(policies);
        param = param.replaceAll("messageTtlInSeconds", "message_ttl_in_seconds")
                .replaceAll("retentionPolicies", "retention_policies");
        HttpUtils.request(restTemplate, clusterInfo.getAdminUrls(QUERY_NAMESPACE_PATH + InlongConstants.SLASH + tenant
                + InlongConstants.SLASH + namespaceName), HttpMethod.PUT, param, headers);
    }
Creates a new pulsar namespace with the specified policies.

@param restTemplate spring framework RestTemplate
@param clusterInfo pulsar cluster info
@param tenant pulsar namespace name
@param namespaceName pulsar namespace name
@param policies pulsar namespace policies info
@throws Exception any exception if occurred
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java