public String kafkaAuthorizationErrorMessage(final Exception e) {
    return errorMessages.kafkaAuthorizationErrorMessage(e);
  }
@Test
  public void shouldReturnForbiddenKafkaErrorMessageString() {
    final String error = errorHandler.kafkaAuthorizationErrorMessage(exception);
    assertThat(error, is(SOME_KAFKA_ERROR));
  }