public EndpointResponse accessDeniedFromKafkaResponse(final Exception e) {
    return constructAccessDeniedFromKafkaResponse(errorMessages.kafkaAuthorizationErrorMessage(e));
  }
@Test
  public void shouldReturnForbiddenKafkaResponse() {
    final EndpointResponse response = errorHandler.accessDeniedFromKafkaResponse(exception);
    assertThat(response.getStatus(), is(403));
    assertThat(response.getEntity(), is(instanceOf(KsqlErrorMessage.class)));
    assertThat(((KsqlErrorMessage) response.getEntity()).getMessage(), is(SOME_KAFKA_ERROR));
  }