@Override
  public void checkTopicAccess(
      final KsqlSecurityContext securityContext,
      final String topicName,
      final AclOperation operation
  ) {
    checkAccess(new CacheKey(securityContext,
        AuthObjectType.TOPIC,
        topicName,
        operation));

  }
@Test
  public void shouldThrowExceptionWhenBackendValidatorThrowsAnException() {
    // Given
    doThrow(RuntimeException.class).when(backendValidator)
        .checkTopicAccess(securityContext, TOPIC_1, AclOperation.READ);

    // When:
    assertThrows(
        RuntimeException.class,
        () -> cache.checkTopicAccess(securityContext, TOPIC_1, AclOperation.READ)
    );
  }