public QueueResourceOperator getInstance(String mqType) {
        return operatorList.stream()
                .filter(inst -> inst.accept(mqType))
                .findFirst()
                .orElseThrow(() -> new BusinessException(ErrorCodeEnum.MQ_TYPE_NOT_SUPPORT,
                        String.format(ErrorCodeEnum.MQ_TYPE_NOT_SUPPORT.getMessage(), mqType)));
    }
Get a message queue resource operator instance via the given mqType
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/QueueResourceOperatorFactory.java