public static List<PKafkaOffsetProxyResult> getBatchOffsets(List<PKafkaOffsetProxyRequest> requests)
            throws UserException {
        return PROXY_API.getBatchOffsets(requests);
    }
@Test
    public void testWarehouseNotExist() throws UserException {
        new MockUp<WarehouseManager>() {
            @Mock
            public List<Long> getAllComputeNodeIds(long warehouseId) {
                throw ErrorReportException.report(ErrorCode.ERR_UNKNOWN_WAREHOUSE, String.format("id: %d", 1L));
            }
        };

        KafkaUtil.ProxyAPI api = new KafkaUtil.ProxyAPI();
        LoadException e = Assert.assertThrows(LoadException.class, () -> api.getBatchOffsets(null));
        Assert.assertEquals("Failed to send get kafka partition info request. err: Warehouse id: 1 not exist.", e.getMessage());
    }