@Test
    @Order(9)
    @Transactional
    public void testSourceCorrectParamsOfTaggedSortCluster() {
        SortSourceConfigResponse response = sortService.getSourceConfig(TEST_CLUSTER_2, TEST_TASK_2, "");
        Assertions.assertEquals(0, response.getCode());
        Assertions.assertNotNull(response.getMd5());
        Assertions.assertNotNull(response.getMsg());
        CacheZoneConfig config = response.getData();
        Assertions.assertNotNull(config);
        Assertions.assertEquals(TEST_CLUSTER_2, config.getSortClusterName());
        Assertions.assertEquals(TEST_TASK_2, config.getSortTaskId());
        Assertions.assertEquals(1, config.getCacheZones().size());
        CacheZone zone = config.getCacheZones().get("testPulsar");
        Assertions.assertNotNull(zone);
        Assertions.assertEquals("testPulsar", zone.getZoneName());
        Assertions.assertEquals(1, zone.getTopics().size());

        response = sortService.getSourceConfig(TEST_CLUSTER_3, TEST_TASK_3, "");
        Assertions.assertEquals(0, response.getCode());
        Assertions.assertNotNull(response.getMd5());
        Assertions.assertNotNull(response.getMsg());
        config = response.getData();
        Assertions.assertNotNull(config);
        Assertions.assertEquals(TEST_CLUSTER_3, config.getSortClusterName());
        Assertions.assertEquals(TEST_TASK_3, config.getSortTaskId());
        Assertions.assertEquals(1, config.getCacheZones().size());
        zone = config.getCacheZones().get("backupPulsar");
        Assertions.assertNotNull(zone);
        Assertions.assertEquals("backupPulsar", zone.getZoneName());
        Assertions.assertEquals(1, zone.getTopics().size());
    }
Sort service test for {@link SortService}
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java