private void preparePulsar(String pulsarName, boolean isConsumable, String tag) {
        PulsarClusterRequest request = new PulsarClusterRequest();
        request.setUrl("testServiceUrl");
        request.setName(pulsarName);
        request.setType(ClusterType.PULSAR);
        request.setClusterTags(tag);
        request.setInCharges(TEST_CREATOR);
        request.setVersion(InlongConstants.INITIAL_VERSION);
        String extTag = "zone=" + TEST_TAG
                + "&producer=true"
                + "&consumer=" + (isConsumable ? "true" : "false");
        request.setExtTag(extTag);
        request.setExtParams("{\"pulsarTenant\":\"testTenant\","
                + "\"authentication\":\"testAuth\",\"adminUrl\":\"testAdmin\"}");
        clusterService.save(request, "test operator");
    }
Sort service test for {@link SortService}
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java