@Override
  public void checkTopicAccess(
      final KsqlSecurityContext securityContext,
      final String topicName,
      final AclOperation operation
  ) {
    authorizationProvider.checkPrivileges(
        securityContext,
        AuthObjectType.TOPIC,
        topicName,
        ImmutableList.of(operation)
    );
  }
@Test
    public void shouldCheckTopicPrivilegesOnProvidedAccessValidator() {
        // When
        accessValidator.checkTopicAccess(securityContext, "topic1", AclOperation.WRITE);

        // Then
        verify(authorizationProvider, times(1))
            .checkPrivileges(
                securityContext,
                AuthObjectType.TOPIC,
                "topic1",
                ImmutableList.of(AclOperation.WRITE));
    }