@Override
    public GetTelemetrySubscriptionsResponse getErrorResponse(int throttleTimeMs, Throwable e) {
        GetTelemetrySubscriptionsResponseData responseData = new GetTelemetrySubscriptionsResponseData()
                .setErrorCode(Errors.forException(e).code())
                .setThrottleTimeMs(throttleTimeMs);
        return new GetTelemetrySubscriptionsResponse(responseData);
    }
@Test
    public void testGetErrorResponse() {
        GetTelemetrySubscriptionsRequest req = new GetTelemetrySubscriptionsRequest(new GetTelemetrySubscriptionsRequestData(), (short) 0);
        GetTelemetrySubscriptionsResponse response = req.getErrorResponse(0, Errors.CLUSTER_AUTHORIZATION_FAILED.exception());
        assertEquals(Collections.singletonMap(Errors.CLUSTER_AUTHORIZATION_FAILED, 1), response.errorCounts());
    }