private void prepareStreamId(String groupId, String streamId, String topic) {
        InlongStreamRequest request = new InlongStreamRequest();
        request.setInlongGroupId(groupId);
        request.setInlongStreamId(streamId);
        request.setName("test_stream_name");
        request.setMqResource(topic);
        request.setVersion(InlongConstants.INITIAL_VERSION);
        List<InlongStreamExtInfo> extInfos = new ArrayList<>();
        InlongStreamExtInfo ext = new InlongStreamExtInfo();
        extInfos.add(ext);
        ext.setInlongStreamId(streamId);
        ext.setInlongGroupId(groupId);
        ext.setKeyName(ClusterSwitch.BACKUP_MQ_RESOURCE);
        ext.setKeyValue("backup_" + topic);
        request.setExtList(extInfos);
        streamService.save(request, GLOBAL_OPERATOR);
    }
Sort service test for {@link SortService}
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/SortServiceImplTest.java